Update airbyte_cdk/sources/declarative/interpolation/macros.py

maxi297 · aaronsteers · web-flow · commit 8bcc43c15f0f · 2025-04-08T10:17:25.000-04:00
Co-authored-by: Aaron ("AJ") Steers &lt;aj@airbyte.io&gt;
diff --git a/airbyte_cdk/sources/declarative/interpolation/macros.py b/airbyte_cdk/sources/declarative/interpolation/macros.py
@@ -177,7 +177,8 @@ def format_datetime(
         dt_datetime = (
             datetime.datetime.strptime(dt, input_format) if input_format else str_to_datetime(dt)
         )
-    dt_datetime = dt_datetime.replace(tzinfo=pytz.utc)
+    if dt_datetime.tzinfo is None:
+        dt_datetime = dt_datetime.replace(tzinfo=pytz.utc)
     return DatetimeParser().format(dt=dt_datetime, format=format)
 
 

Original file line number	Diff line number	Diff line change
`@@ -177,7 +177,8 @@ def format_datetime(`
`177`	`177`	`dt_datetime = (`
`178`	`178`	`datetime.datetime.strptime(dt, input_format) if input_format else str_to_datetime(dt)`
`179`	`179`	`)`
`180`		`- dt_datetime = dt_datetime.replace(tzinfo=pytz.utc)`
	`180`	`+ if dt_datetime.tzinfo is None:`
	`181`	`+ dt_datetime = dt_datetime.replace(tzinfo=pytz.utc)`
`181`	`182`	`return DatetimeParser().format(dt=dt_datetime, format=format)`
`182`	`183`
`183`	`184`