in iot_client.py [0:0]
def jobs_handler(self, jobs):
for j in jobs:
print("Processing job: {0}".format(j['jobId']))
get_job_payload = {
"clientToken": str(uuid.uuid4()),
"includeJobDocument": True
}
base_job_topic = "$aws/things/{0}/jobs/{1}/".format(self.thing_name, j['jobId'])
self.publish(
"{0}get".format(base_job_topic),
json.dumps(get_job_payload),
0
)