Skip to content

Commit 113082e

Browse files
refactor: Replace use of pendulum with stdlib (#400)
1 parent c182c93 commit 113082e

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

target_postgres/sinks.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,10 +1,10 @@
11
"""Postgres target sink class, which handles writing streams."""
22

3+
import datetime
34
import uuid
45
from typing import Any, Dict, Iterable, List, Optional, Sequence, Union, cast
56

67
import sqlalchemy as sa
7-
from pendulum import now
88
from singer_sdk.sinks import SQLSink
99
from sqlalchemy.sql import Executable
1010
from sqlalchemy.sql.expression import bindparam
@@ -338,7 +338,7 @@ def activate_version(self, new_version: int) -> None:
338338
if not self.connector.table_exists(self.full_table_name):
339339
return
340340

341-
deleted_at = now()
341+
deleted_at = datetime.datetime.now(tz=datetime.timezone.utc)
342342

343343
with self.connector._connect() as connection, connection.begin():
344344
# Theoretically these errors should never appear because we always create

0 commit comments

Comments
 (0)