fix(bq-syncer): ensure sync in oder

daoleno · Jan 15, 2024 · 5f2bdf8 · 5f2bdf8
1 parent 19399ff
commit 5f2bdf8
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/bq-syncer/sync.py b/bq-syncer/sync.py
@@ -169,6 +169,7 @@ def process_table(table, conn, dataset_ref, bqclient, idx):
     SELECT {', '.join(fields)}
     FROM `{table_ref}`
     WHERE datastream_metadata.source_timestamp > {last_timestamp}
+    ORDER BY datastream_metadata.source_timestamp ASC
     """
     query_job = bqclient.query(query)
     pageNum = 0