We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent e9b734a commit 45dd193Copy full SHA for 45dd193
scripts/jobs/planning/tascomi_create_daily_snapshot.py
@@ -83,13 +83,13 @@ def loadIncrementsSinceDate(
83
) -> DataFrame:
84
"""
85
Loads increments from the specified catalog table starting from a given date.
86
- If the provided date is None, it defaults to 30 days ago.
+ If the provided date is None, it defaults to 60 days ago.
87
88
Returns:
89
DataFrame: A Spark DataFrame containing the loaded increments.
90
91
if date is None:
92
- date = (datetime.now() - timedelta(days=30)).strftime("%Y%m%d") # default date
+ date = (datetime.now() - timedelta(days=60)).strftime("%Y%m%d") # default date
93
increment_ddf = glueContext.create_dynamic_frame.from_catalog(
94
name_space=name_space,
95
table_name=increment_table_name,
0 commit comments