Quick process
Browse files- API/app.py +6 -7
API/app.py
CHANGED
|
@@ -210,16 +210,15 @@ async def process_post(post_id, session, semaphore):
|
|
| 210 |
chunks.append((start, end))
|
| 211 |
start = end
|
| 212 |
|
| 213 |
-
exif_data_list = []
|
| 214 |
for s, e in chunks:
|
| 215 |
chunk_tasks = [get_exif(image_urls[i], session) for i in range(s, e)]
|
| 216 |
-
|
| 217 |
-
|
| 218 |
-
for image_url, metadata in zip(image_urls, exif_data_list):
|
| 219 |
-
exif_type = determine_exif_type(metadata)
|
| 220 |
-
if exif_type not in ['photoshop', 'celsys', None]:
|
| 221 |
-
return post_id, image_url
|
| 222 |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 223 |
return post_id, None
|
| 224 |
except:
|
| 225 |
return post_id, None
|
|
|
|
| 210 |
chunks.append((start, end))
|
| 211 |
start = end
|
| 212 |
|
|
|
|
| 213 |
for s, e in chunks:
|
| 214 |
chunk_tasks = [get_exif(image_urls[i], session) for i in range(s, e)]
|
| 215 |
+
results = await asyncio.gather(*chunk_tasks)
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 216 |
|
| 217 |
+
for image_url, metadata in zip(image_urls[s:e], results):
|
| 218 |
+
exif_type= determine_exif_type(metadata)
|
| 219 |
+
if exif_type not in ['photoshop', 'celsys', None]:
|
| 220 |
+
return post_id, image_url
|
| 221 |
+
|
| 222 |
return post_id, None
|
| 223 |
except:
|
| 224 |
return post_id, None
|