Lee Mendelowitz
12/03/2020, 10:33 PMDylan
waiter_definition
but I’m unsure. Curious to see what others in the community thinkLee Mendelowitz
12/03/2020, 10:55 PMwaiter_kwargs
:
from prefect.tasks.aws.client_waiter import AWSClientWait
batch_waiter = AWSClientWait(client = 'batch', waiter_name = 'JobComplete')
batch_waiter.run(waiter_kwargs = {'jobs' : ["<jobId>"]})
It seems that the waiter_kwargs
maps to the arguments for the boto3
batch client call to `describe_jobs`:
import boto3
client = boto3.client('batch')
res = client.describe_jobs(jobs = ["<jobId"])
Dylan