flytekitplugins.awsbatch.AWSBatchConfig

class flytekitplugins.awsbatch.AWSBatchConfig(parameters=None, schedulingPriority=None, platformCapabilities='EC2', propagateTags=None, tags=None)[source]

Use this to configure SubmitJobInput for a AWS batch job. Task’s marked with this will automatically execute natively onto AWS batch service. Refer to AWS SubmitJobInput for more detail: https://docs.aws.amazon.com/sdk-for-go/api/service/batch/#SubmitJobInput

Methods

Parameters:
  • parameters (Dict[str, str] | None)

  • schedulingPriority (int | None)

  • platformCapabilities (str)

  • propagateTags (bool | None)

  • tags (Dict[str, str] | None)

classmethod from_dict(kvs, *, infer_missing=False)
Parameters:

kvs (dict | list | str | int | float | bool | None)

Return type:

A

classmethod from_json(s, *, parse_float=None, parse_int=None, parse_constant=None, infer_missing=False, **kw)
Parameters:

s (str | bytes | bytearray)

Return type:

A

classmethod schema(*, infer_missing=False, only=None, exclude=(), many=False, context=None, load_only=(), dump_only=(), partial=False, unknown=None)
Parameters:
Return type:

SchemaF[A]

to_dict()[source]
to_json(*, skipkeys=False, ensure_ascii=True, check_circular=True, allow_nan=True, indent=None, separators=None, default=None, sort_keys=False, **kw)
Parameters:
Return type:

str

Attributes

dataclass_json_config = None
parameters: Dict[str, str] | None = None
platformCapabilities: str = 'EC2'
propagateTags: bool | None = None
schedulingPriority: int | None = None
tags: Dict[str, str] | None = None