WIP reprocess dags

Dragos0000 · Dragos0000 · commit baf4c867d4cf · 2025-05-22T13:46:34.000+01:00
diff --git a/dags/reprocess_notices_from_backlog_by_status.py b/dags/reprocess_notices_from_backlog_by_status.py
@@ -30,8 +30,8 @@
             title="Notice Statuses",
             description="Required. List of notice statuses to reprocess. Example: [\"NORMALISED_METADATA\", \"DISTILLED\"]"
         ),
-        START_DATE_DAG_PARAM: Param(default="", type="string", description="Start date (YYYY-MM-DD)"),
-        END_DATE_DAG_PARAM: Param(default="", type="string", description="End date (YYYY-MM-DD)")
+        START_DATE_DAG_PARAM: Param(default="", type=["null", "string"], format="date", description="Start date (YYYY-MM-DD)"),
+        END_DATE_DAG_PARAM: Param(default="", type=["null", "string"], format="date", description="End date (YYYY-MM-DD)")
     }
     )
 def reprocess_notices_from_backlog_by_status():

Original file line number	Diff line number	Diff line change
`@@ -30,8 +30,8 @@`
`30`	`30`	`title="Notice Statuses",`
`31`	`31`	`description="Required. List of notice statuses to reprocess. Example: [\"NORMALISED_METADATA\", \"DISTILLED\"]"`
`32`	`32`	`),`
`33`		`- START_DATE_DAG_PARAM: Param(default="", type="string", description="Start date (YYYY-MM-DD)"),`
`34`		`- END_DATE_DAG_PARAM: Param(default="", type="string", description="End date (YYYY-MM-DD)")`
	`33`	`+ START_DATE_DAG_PARAM: Param(default="", type=["null", "string"], format="date", description="Start date (YYYY-MM-DD)"),`
	`34`	`+ END_DATE_DAG_PARAM: Param(default="", type=["null", "string"], format="date", description="End date (YYYY-MM-DD)")`
`35`	`35`	`}`
`36`	`36`	`)`
`37`	`37`	`def reprocess_notices_from_backlog_by_status():`