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
- 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.