in src/aws_interfaces/iot_interface.py [0:0]
def cancel_job(self, jobId):
logging.info('canceling jobId %s', jobId)
try:
self.client.cancel_job(jobId=jobId)
except ClientError as e:
return False, str(e)
while True:
try:
response = self.client.describe_job(jobId=jobId)
job_dsb = response.get('job')
status = job_dsb.get('status')
if status == 'CANCELED':
break
time.sleep(1)
except ClientError as e:
break
return True, None