## We poll for the processing Job at intervals 
get_processing_job_status = LambdaStep(
    state_id="GetDataProcessingJob",
    parameters={  
        "FunctionName": "arn:aws:lambda:eu-west-1:1234567890:function:GetProcessingJobStatus", #replace with the name of the function you created
        "Payload": {  
           "JobName": create_processing_job_step.output()['Payload']['JobName']
        }
    }
)

check_job_wait_state = Wait(
    state_id="Wait",
    seconds=60
)