QuivrHQ/quivr
1
1
Fork 0
mirror of https://github.com/QuivrHQ/quivr.git synced 2024-09-11 14:36:35 +03:00
Code Issues Packages Projects Releases Wiki Activity

Fix integration sync bug

Browse Source
This commit is contained in:
Stan Girard 2024-04-06 18:30:21 -07:00
parent 1c087aa1ba
commit bc770462cf
1 changed files with 12 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
backend/celery_worker.py
View File

@ -1,7 +1,7 @@
import asyncio
import io
import os
from datetime import datetime, timedelta, timezone
from datetime import datetime, timezone
from celery.schedules import crontab
from celery_config import celery
@ -191,15 +191,17 @@ def process_integration_brain_sync():
# only call process_integration_brain_sync_user_brain if more than 1 day has passed since the last sync
if not integrations:
return
for integration in integrations:
print(f"last_synced: {integration.last_synced}") # Add this line
last_synced = datetime.strptime(
integration.last_synced, "%Y-%m-%dT%H:%M:%S.%f%z"
)
if last_synced < time - timedelta(hours=12):
process_integration_brain_sync_user_brain.delay(
brain_id=integration.brain_id, user_id=integration.user_id
)
# TODO fix this
# for integration in integrations:
# print(f"last_synced: {integration.last_synced}")
# print(f"Integration Name: {integration.name}")
# last_synced = datetime.strptime(
# integration.last_synced, "%Y-%m-%dT%H:%M:%S.%f%z"
# )
# if last_synced < time - timedelta(hours=12) and integration.name == "notion":
# process_integration_brain_sync_user_brain.delay(
# brain_id=integration.brain_id, user_id=integration.user_id
# )
celery.conf.beat_schedule = {