diff --git a/singer_sdk/sinks/core.py b/singer_sdk/sinks/core.py index 7d9d24a3c..dcac2bee4 100644 --- a/singer_sdk/sinks/core.py +++ b/singer_sdk/sinks/core.py @@ -456,7 +456,7 @@ def _add_sdc_metadata_to_record( or datetime.datetime.now(tz=datetime.timezone.utc) ).isoformat() record["_sdc_deleted_at"] = record.get("_sdc_deleted_at") - record["_sdc_sequence"] = int(round(time.time() * 1000)) + record["_sdc_sequence"] = round(time.time() * 1000) record["_sdc_table_version"] = message.get("version") record["_sdc_sync_started_at"] = self.sync_started_at diff --git a/tests/samples/conftest.py b/tests/samples/conftest.py index 719f2e20c..1202dc688 100644 --- a/tests/samples/conftest.py +++ b/tests/samples/conftest.py @@ -19,7 +19,7 @@ def csv_config(outdir: str) -> dict: @pytest.fixture -def _sqlite_sample_db(sqlite_connector): +def sqlite_sample_db(sqlite_connector: SQLiteConnector): """Return a path to a newly constructed sample DB.""" with sqlite_connector._connect() as conn, conn.begin(): for t in range(3):