Skip to main content

​
prefect_aws.batch

Tasks for interacting with AWS Batch

​
Functions

​
abatch_submit 

abatch_submit(job_name: str, job_queue: str, job_definition: str, aws_credentials: AwsCredentials, **batch_kwargs: Optional[Dict[str, Any]]) -> str
Asynchronously submit a job to the AWS Batch job service. Args:
  • job_name: The AWS batch job name.
  • job_queue: Name of the AWS batch job queue.
  • job_definition: The AWS batch job definition.
  • aws_credentials: Credentials to use for authentication with AWS.
  • **batch_kwargs: Additional keyword arguments to pass to the boto3 submit_job function. See the documentation for submit_job for more details.
Returns:
  • The id corresponding to the job.

​
batch_submit 

batch_submit(job_name: str, job_queue: str, job_definition: str, aws_credentials: AwsCredentials, **batch_kwargs: Optional[Dict[str, Any]]) -> str
Submit a job to the AWS Batch job service. Args:
  • job_name: The AWS batch job name.
  • job_queue: Name of the AWS batch job queue.
  • job_definition: The AWS batch job definition.
  • aws_credentials: Credentials to use for authentication with AWS.
  • **batch_kwargs: Additional keyword arguments to pass to the boto3 submit_job function. See the documentation for submit_job for more details.
Returns:
  • The id corresponding to the job.