|
12 | 12 | import litellm
|
13 | 13 |
|
14 | 14 | litellm.num_retries = 0
|
| 15 | +import asyncio |
15 | 16 | import logging
|
16 | 17 |
|
17 | 18 | from litellm import create_fine_tuning_job
|
@@ -112,3 +113,58 @@ async def test_create_fine_tune_jobs_async():
|
112 | 113 | assert response.status == "cancelled"
|
113 | 114 | assert response.id == create_fine_tuning_response.id
|
114 | 115 | pass
|
| 116 | + |
| 117 | + |
| 118 | +@pytest.mark.asyncio |
| 119 | +async def test_azure_create_fine_tune_jobs_async(): |
| 120 | + verbose_logger.setLevel(logging.DEBUG) |
| 121 | + file_name = "azure_fine_tune.jsonl" |
| 122 | + _current_dir = os.path.dirname(os.path.abspath(__file__)) |
| 123 | + file_path = os.path.join(_current_dir, file_name) |
| 124 | + |
| 125 | + file_obj = await litellm.acreate_file( |
| 126 | + file=open(file_path, "rb"), |
| 127 | + purpose="fine-tune", |
| 128 | + custom_llm_provider="azure", |
| 129 | + api_key=os.getenv("AZURE_SWEDEN_API_KEY"), |
| 130 | + api_base="https://my-endpoint-sweden-berri992.openai.azure.com/", |
| 131 | + ) |
| 132 | + print("Response from creating file=", file_obj) |
| 133 | + |
| 134 | + await asyncio.sleep(5) |
| 135 | + |
| 136 | + create_fine_tuning_response = await litellm.acreate_fine_tuning_job( |
| 137 | + model="gpt-35-turbo-1106", |
| 138 | + training_file=file_obj.id, |
| 139 | + custom_llm_provider="azure", |
| 140 | + api_key=os.getenv("AZURE_SWEDEN_API_KEY"), |
| 141 | + api_base="https://my-endpoint-sweden-berri992.openai.azure.com/", |
| 142 | + ) |
| 143 | + |
| 144 | + print("response from litellm.create_fine_tuning_job=", create_fine_tuning_response) |
| 145 | + |
| 146 | + assert create_fine_tuning_response.id is not None |
| 147 | + assert create_fine_tuning_response.model == "gpt-35-turbo-1106" |
| 148 | + |
| 149 | + # # list fine tuning jobs |
| 150 | + # print("listing ft jobs") |
| 151 | + # ft_jobs = await litellm.alist_fine_tuning_jobs(limit=2) |
| 152 | + # print("response from litellm.list_fine_tuning_jobs=", ft_jobs) |
| 153 | + # assert len(list(ft_jobs)) > 0 |
| 154 | + |
| 155 | + # # delete file |
| 156 | + |
| 157 | + # await litellm.afile_delete( |
| 158 | + # file_id=file_obj.id, |
| 159 | + # ) |
| 160 | + |
| 161 | + # # cancel ft job |
| 162 | + # response = await litellm.acancel_fine_tuning_job( |
| 163 | + # fine_tuning_job_id=create_fine_tuning_response.id, |
| 164 | + # ) |
| 165 | + |
| 166 | + # print("response from litellm.cancel_fine_tuning_job=", response) |
| 167 | + |
| 168 | + # assert response.status == "cancelled" |
| 169 | + # assert response.id == create_fine_tuning_response.id |
| 170 | + # pass |
0 commit comments