Update app.py
Browse files
app.py
CHANGED
|
@@ -564,6 +564,7 @@ async def websearch_endpoint(request: Request):
|
|
| 564 |
# If the BingScraperAPI.fetch accepts multiple providers in one call (as your sample),
|
| 565 |
# we iterate it directly and stream tuples as they arrive.
|
| 566 |
# This is the simplest/fastest approach when the library does provider-level parallelism.
|
|
|
|
| 567 |
async for provider, result in api.fetch(providers=providers, param=params):
|
| 568 |
payload = {"provider": provider, "result": result, "ts": time.time()}
|
| 569 |
try:
|
|
@@ -573,6 +574,7 @@ async def websearch_endpoint(request: Request):
|
|
| 573 |
safe_payload = {"provider": provider, "result": str(result), "ts": time.time()}
|
| 574 |
yield dumps(safe_payload) + b"\n"
|
| 575 |
except TypeError:
|
|
|
|
| 576 |
# If api.fetch signature differs, attempt a safe fallback:
|
| 577 |
# Launch one fetch task per provider in parallel and collect results in an async queue.
|
| 578 |
q: asyncio.Queue = asyncio.Queue()
|
|
|
|
| 564 |
# If the BingScraperAPI.fetch accepts multiple providers in one call (as your sample),
|
| 565 |
# we iterate it directly and stream tuples as they arrive.
|
| 566 |
# This is the simplest/fastest approach when the library does provider-level parallelism.
|
| 567 |
+
print(providers , params)
|
| 568 |
async for provider, result in api.fetch(providers=providers, param=params):
|
| 569 |
payload = {"provider": provider, "result": result, "ts": time.time()}
|
| 570 |
try:
|
|
|
|
| 574 |
safe_payload = {"provider": provider, "result": str(result), "ts": time.time()}
|
| 575 |
yield dumps(safe_payload) + b"\n"
|
| 576 |
except TypeError:
|
| 577 |
+
print("ERROR HAD")
|
| 578 |
# If api.fetch signature differs, attempt a safe fallback:
|
| 579 |
# Launch one fetch task per provider in parallel and collect results in an async queue.
|
| 580 |
q: asyncio.Queue = asyncio.Queue()
|