pass timezone
This commit is contained in:
@@ -1,3 +1,4 @@
|
|||||||
|
import os
|
||||||
from collections.abc import Iterator
|
from collections.abc import Iterator
|
||||||
from datetime import datetime
|
from datetime import datetime
|
||||||
from glob import glob
|
from glob import glob
|
||||||
@@ -21,7 +22,7 @@ SOURCES = ["plato", "sounds"]
|
|||||||
logger = structlog.get_logger()
|
logger = structlog.get_logger()
|
||||||
|
|
||||||
daily_partitions_def = dg.DailyPartitionsDefinition(
|
daily_partitions_def = dg.DailyPartitionsDefinition(
|
||||||
start_date="2024-09-01", end_offset=1
|
start_date="2024-09-01", end_offset=1, timezone=os.environ["TZ"]
|
||||||
)
|
)
|
||||||
multi_partitions_def = dg.MultiPartitionsDefinition(
|
multi_partitions_def = dg.MultiPartitionsDefinition(
|
||||||
{
|
{
|
||||||
|
|||||||
Reference in New Issue
Block a user