admin/OpenJarvis
1
0
Fork 0
mirror of https://github.com/open-jarvis/OpenJarvis.git synced 2026-07-30 10:52:15 +00:00
Code Issues Packages Projects Releases Wiki Activity

style: fix line length in sync_engine.py

Browse Source 
Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>
This commit is contained in:
krypticmouse
2026-03-26 00:10:42 +00:00
co-authored by Claude Opus 4.6
parent 138fb8a3d0
commit c8182be95a
1 changed files with 8 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/openjarvis/connectors/sync_engine.py
+8 -6
View File
@@ -135,11 +135,12 @@ class SyncEngine:
return items_ingested
def get_checkpoint(self, connector_id: str) -> Optional[Dict[str, Any]]:
"""Return the last checkpoint for *connector_id*, or ``None`` if never synced."""
row = self._conn.execute(
"SELECT items_synced, cursor, last_sync, error FROM sync_state WHERE connector_id = ?",
(connector_id,),
).fetchone()
"""Return the last checkpoint, or ``None`` if never synced."""
sql = (
"SELECT items_synced, cursor, last_sync, error"
" FROM sync_state WHERE connector_id = ?"
)
row = self._conn.execute(sql, (connector_id,)).fetchone()
if row is None:
return None
@@ -167,7 +168,8 @@ class SyncEngine:
now = datetime.now(tz=timezone.utc).isoformat()
self._conn.execute(
"""
INSERT INTO sync_state (connector_id, items_synced, cursor, last_sync, error)
INSERT INTO sync_state
(connector_id, items_synced, cursor, last_sync, error)
VALUES (?, ?, ?, ?, ?)
ON CONFLICT(connector_id) DO UPDATE SET
items_synced = excluded.items_synced,