client = ApifyClientAsync(token=settings.APIFY_API_TOKEN)
run = await client.actor(actor.value).start(run_input=run_input)
processed = 0
while True:
await asyncio.sleep(2)
data = client.dataset(run["defaultDatasetId"]).iterate_items(offset=processed)
async for item in data:
dataset.append(item)
processed += 1
logger.info(f"processing item: {item.get('url')}")
run_status = await client.run(run["id"]).get()
if run_status.get("status", None) == "RUNNING":
logger.info("Run is still running")
continue
else:
logger.info("Run is finished.")
break
client = ApifyClientAsync(token=settings.APIFY_API_TOKEN)
run = await client.actor(actor.value).start(run_input=run_input)
processed = 0
while True:
await asyncio.sleep(2)
data = client.dataset(run["defaultDatasetId"]).iterate_items(offset=processed)
async for item in data:
dataset.append(item)
processed += 1
logger.info(f"processing item: {item.get('url')}")
run_status = await client.run(run["id"]).get()
if run_status.get("status", None) == "RUNNING":
logger.info("Run is still running")
continue
else:
logger.info("Run is finished.")
break