libera_utils.aws.manual_processing.step_function_trigger#

libera_utils.aws.manual_processing.step_function_trigger(algorithm_name: str | ProcessingStepIdentifier, applicable_day: str | date | datetime, *, boto_session: Session, verify: bool = False, wait_time: float = 60) → list[ULID]#

Manually trigger a single processing step for a single applicable date.

This is a thin special case of start_manual_processing(): it submits a ManualProcessing event using the SDC’s default DAG with process_downstream=False and the single step as the start node, which the Job Creator reduces to a one-node job. Input/output products for the node come from the SDC’s static DAG asset, so no custom DAG is needed. Input products are assumed to already be ingested into the SDC.

Parameters:

  • algorithm_name (str or ProcessingStepIdentifier) – The processing step to run.

  • applicable_day (str, date, or datetime) – The day of data to process.

  • boto_session (boto3.Session) – Boto3 session used for all AWS interactions.

  • verify (bool, optional) – When True, poll the Coordination Table to confirm the job was created and that its single start node moves from PENDING to RUNNING. Defaults to False. The step function console URL is logged regardless of this flag.

  • wait_time (float, optional) – Maximum seconds to wait for each verification stage (job creation, then start node running), by default 60.

Returns:

The job ids associated with the submitted job.

Return type:

list[ULID]