diff --git a/pipe/aepg600m/aepg600m_cron_daily_and_date_control.yaml b/pipe/aepg600m/aepg600m_cron_daily_and_date_control.yaml index 6b550948f..10f618a22 100644 --- a/pipe/aepg600m/aepg600m_cron_daily_and_date_control.yaml +++ b/pipe/aepg600m/aepg600m_cron_daily_and_date_control.yaml @@ -11,7 +11,7 @@ transform: # This is because some kafka topics start with dfir instead of simply , which the trino loader cannot handle LAG_DAYS_END: "2" # Default is 2. Don't go lower than 2. START_DATE: "2014-12-24" - # END_DATE: "2024-01-06" + END_DATE: "2018-01-06" OUT_PATH_KAFKA: /pfs/out/kafka OUT_PATH_TRINO: /pfs/out/trino SOURCE_TYPE_NONHEATED: "aepg600m" diff --git a/pipe/precipWeighing/precipWeighing_cron_monthly_and_pub_control.yaml b/pipe/precipWeighing/precipWeighing_cron_monthly_and_pub_control.yaml index e04869258..29e366622 100644 --- a/pipe/precipWeighing/precipWeighing_cron_monthly_and_pub_control.yaml +++ b/pipe/precipWeighing/precipWeighing_cron_monthly_and_pub_control.yaml @@ -10,7 +10,7 @@ transform: # END_DATE can be set or unset (comment or remove line to unset). If unset, end month will be last month. OUT_PATH: /pfs/out START_MONTH: "2015-01" - # END_MONTH: "2023-12" # Inclusive. Run the pipeline with END_MONTH set to initialize, then comment out and update pipeline (no reprocess) to let the cron take over + END_MONTH: "2017-12" # Inclusive. Run the pipeline with END_MONTH set to initialize, then comment out and update pipeline (no reprocess) to let the cron take over stdin: - "#!/bin/bash" - ./cron_monthly_and_pub_control/populate_pub_months.sh