|
1 | 1 | import logging |
2 | 2 | import sys |
3 | 3 | from datetime import datetime |
4 | | -from typing import Any, Dict, Optional, Union |
| 4 | +from typing import Any, Dict, Optional |
5 | 5 |
|
6 | 6 | import requests |
7 | 7 | import sseclient # type: ignore |
@@ -57,6 +57,7 @@ def verify_api_key() -> None: |
57 | 57 | if together.api_key is None: |
58 | 58 | raise together.AuthenticationError(together.MISSING_API_KEY_MESSAGE) |
59 | 59 |
|
| 60 | + |
60 | 61 | def extract_time(json_obj: Dict[str, Any]) -> int: |
61 | 62 | try: |
62 | 63 | return int(json_obj["created_at"]) |
@@ -98,7 +99,9 @@ def create_post_request( |
98 | 99 | raise together.ResponseError(e) |
99 | 100 |
|
100 | 101 | if response.status_code == 429: |
101 | | - raise together.RateLimitError(message="Too many requests received. Please pace your requests.") |
| 102 | + raise together.RateLimitError( |
| 103 | + message="Too many requests received. Please pace your requests." |
| 104 | + ) |
102 | 105 | elif response.status_code == 500: |
103 | 106 | raise Exception("Invalid API key supplied.") |
104 | 107 | elif response.status_code == 401: |
@@ -136,7 +139,9 @@ def create_get_request( |
136 | 139 | raise together.ResponseError(e) |
137 | 140 |
|
138 | 141 | if response.status_code == 429: |
139 | | - raise together.RateLimitError(message="Too many requests received. Please pace your requests.") |
| 142 | + raise together.RateLimitError( |
| 143 | + message="Too many requests received. Please pace your requests." |
| 144 | + ) |
140 | 145 | elif response.status_code == 500: |
141 | 146 | raise Exception("Invalid API key supplied.") |
142 | 147 | elif response.status_code == 401: |
|
0 commit comments