Spaces:
Running
Running
Update alisto_project/backend/ingest_reddit.py
Browse files
alisto_project/backend/ingest_reddit.py
CHANGED
|
@@ -422,7 +422,7 @@ async def scrape_reddit():
|
|
| 422 |
# --- PHASE 1: FETCH LATEST EXISTING POSTS (e.g., last 500) ---
|
| 423 |
print("π Scanning last 500 posts for missed alerts...")
|
| 424 |
# iterates over the last 500 posts asynchronously
|
| 425 |
-
async for post in subreddit.new(limit=
|
| 426 |
await process_post(post)
|
| 427 |
|
| 428 |
print("β
Historical scan complete")
|
|
|
|
| 422 |
# --- PHASE 1: FETCH LATEST EXISTING POSTS (e.g., last 500) ---
|
| 423 |
print("π Scanning last 500 posts for missed alerts...")
|
| 424 |
# iterates over the last 500 posts asynchronously
|
| 425 |
+
async for post in subreddit.new(limit=10):
|
| 426 |
await process_post(post)
|
| 427 |
|
| 428 |
print("β
Historical scan complete")
|