Spaces:
Sleeping
Sleeping
Update main.py
Browse files
main.py
CHANGED
|
@@ -191,7 +191,6 @@ async def process_batch_job(dataset: Dict[str, Any]):
|
|
| 191 |
"""
|
| 192 |
try:
|
| 193 |
|
| 194 |
-
|
| 195 |
openai_tasks = []
|
| 196 |
for ds in dataset.get('data'):
|
| 197 |
message_id = ds.get('message_id')
|
|
@@ -242,6 +241,7 @@ async def process_batch_job(dataset: Dict[str, Any]):
|
|
| 242 |
supabase.table("batch_processing_details").insert({
|
| 243 |
"batch_job_status": False,
|
| 244 |
"batch_job_id" : batch_job.id
|
|
|
|
| 245 |
}).execute()
|
| 246 |
|
| 247 |
print("Batch sent for processing")
|
|
|
|
| 191 |
"""
|
| 192 |
try:
|
| 193 |
|
|
|
|
| 194 |
openai_tasks = []
|
| 195 |
for ds in dataset.get('data'):
|
| 196 |
message_id = ds.get('message_id')
|
|
|
|
| 241 |
supabase.table("batch_processing_details").insert({
|
| 242 |
"batch_job_status": False,
|
| 243 |
"batch_job_id" : batch_job.id
|
| 244 |
+
"user_id":
|
| 245 |
}).execute()
|
| 246 |
|
| 247 |
print("Batch sent for processing")
|