task

class aws_stepfunction.magic.task.MagicTask(comment: Optional[str] = None, next: Optional[str] = None, end: Optional[bool] = None, input_path: Optional[str] = None, output_path: Optional[str] = None, parameters: Dict[str, Any] = _Nothing.NOTHING, result_selector: Dict[str, Any] = _Nothing.NOTHING, result_path: Optional[str] = None, retry: List[Retry] = _Nothing.NOTHING, catch: List[Catch] = _Nothing.NOTHING, id: str = _Nothing.NOTHING, type: str = 'Task', resource: Optional[str] = None, timeout_seconds: Optional[int] = None, timeout_seconds_path: Optional[str] = None, heartbeat_seconds: Optional[int] = None, heartbeat_seconds_path: Optional[str] = None)[source]
class aws_stepfunction.magic.task.BaseLambdaTask(comment: Optional[str] = None, next: Optional[str] = None, end: Optional[bool] = None, input_path: Optional[str] = None, output_path: Optional[str] = None, parameters: Dict[str, Any] = _Nothing.NOTHING, result_selector: Dict[str, Any] = _Nothing.NOTHING, result_path: Optional[str] = None, retry: List[Retry] = _Nothing.NOTHING, catch: List[Catch] = _Nothing.NOTHING, id: str = _Nothing.NOTHING, type: str = 'Task', resource: Optional[str] = None, timeout_seconds: Optional[int] = None, timeout_seconds_path: Optional[str] = None, heartbeat_seconds: Optional[int] = None, heartbeat_seconds_path: Optional[str] = None, lbd_func_name: str = None, lbd_package: str = None, lbd_handler: str = None, lbd_aws_account_id=None, lbd_aws_region=None, lbd_role: str = None, lbd_code_s3_bucket: str = None, lbd_code_s3_key: str = None, lbd_timeout: int = 3, lbd_memory: int = 128, lbd_runtime: str = 'python3.8')[source]
Parameters

lbd_handler – The lambda function handler name. It is the python module path to the python function implementation. See https://docs.aws.amazon.com/lambda/latest/dg/python-handler.html for more information

lambda_function() cottonformation.res.awslambda.Function[source]

Convert the task to cottonformation Resource declaration object.

class aws_stepfunction.magic.task.LambdaTask(comment: Optional[str] = None, next: Optional[str] = None, end: Optional[bool] = None, input_path: Optional[str] = None, output_path: Optional[str] = None, parameters: Dict[str, Any] = _Nothing.NOTHING, result_selector: Dict[str, Any] = _Nothing.NOTHING, result_path: Optional[str] = None, retry: List[Retry] = _Nothing.NOTHING, catch: List[Catch] = _Nothing.NOTHING, id: str = _Nothing.NOTHING, type: str = 'Task', resource: Optional[str] = None, timeout_seconds: Optional[int] = None, timeout_seconds_path: Optional[str] = None, heartbeat_seconds: Optional[int] = None, heartbeat_seconds_path: Optional[str] = None, lbd_func_name: str = None, lbd_package: str = None, lbd_handler: str = None, lbd_aws_account_id=None, lbd_aws_region=None, lbd_role: str = None, lbd_code_s3_bucket: str = None, lbd_code_s3_key: str = None, lbd_timeout: int = 3, lbd_memory: int = 128, lbd_runtime: str = 'python3.8')[source]

A magic task.

class aws_stepfunction.magic.task.IOHandlerTask(comment: Optional[str] = None, next: Optional[str] = None, end: Optional[bool] = None, input_path: Optional[str] = None, output_path: Optional[str] = None, parameters: Dict[str, Any] = _Nothing.NOTHING, result_selector: Dict[str, Any] = _Nothing.NOTHING, result_path: Optional[str] = None, retry: List[Retry] = _Nothing.NOTHING, catch: List[Catch] = _Nothing.NOTHING, id: str = _Nothing.NOTHING, type: str = 'Task', resource: Optional[str] = None, timeout_seconds: Optional[int] = None, timeout_seconds_path: Optional[str] = None, heartbeat_seconds: Optional[int] = None, heartbeat_seconds_path: Optional[str] = None, lbd_func_name: str = None, lbd_package: str = None, lbd_handler: str = None, lbd_aws_account_id=None, lbd_aws_region=None, lbd_role: str = None, lbd_code_s3_bucket: str = None, lbd_code_s3_key: str = None, lbd_timeout: int = 3, lbd_memory: int = 128, lbd_runtime: str = 'python3.8')[source]

A magic task that can handle input / output in a lambda function.