libera_utils.aws.processing_step_function_trigger#
Module for manually triggering a step function
Functions
|
Start a stepfunction to process a certain days data :param algorithm_name: The name of the algorithm to run as identified by the processing step identifier :type algorithm_name: Union[str, ProcessingStepIdentifier] :param applicable_day: The day to process data for :type applicable_day: Union[str, datetime] :param wait_time: The time to wait between checking the status of the step function, default is 5 seconds for a maximum of ~30 second total wait time :type wait_time: int, optional |
|
CLI handler function for the step function trigger CLI subcommand. |
- libera_utils.aws.processing_step_function_trigger.step_function_trigger(algorithm_name: str | ProcessingStepIdentifier, applicable_day: str | datetime, wait_time: int = 0) str#
Start a stepfunction to process a certain days data :param algorithm_name: The name of the algorithm to run as identified by the processing step identifier :type algorithm_name: Union[str, ProcessingStepIdentifier] :param applicable_day: The day to process data for :type applicable_day: Union[str, datetime] :param wait_time: The time to wait between checking the status of the step function, default is 5 seconds for a maximum of
~30 second total wait time
- Returns:
The resulting status of execution. Returns N/A if n
- Return type:
- libera_utils.aws.processing_step_function_trigger.step_function_trigger_cli_handler(parsed_args: Namespace)#
CLI handler function for the step function trigger CLI subcommand.
- Parameters:
parsed_args (argparse.Namespace) – The parsed object of CLI arguments