in job-worker/npm_job_worker.py [0:0]
def get_job_info(job):
nonce = job['nonce']
jobId = job['id']
inputBucketName = job['data']['inputArtifacts'][0]['location']['s3Location']['bucketName']
inputObjectKey = job['data']['inputArtifacts'][0]['location']['s3Location']['objectKey']
try:
outputBucketName = job['data']['outputArtifacts'][0]['location']['s3Location']['bucketName']
outputObjectKey = job['data']['outputArtifacts'][0]['location']['s3Location']['objectKey']
except IndexError as e:
print('Error getting output Bucket: %s' % str(e))
print('No output artifacts defined, setting outputBucketName and outputObjectKey to []')
outputBucketName = []
outputObjectKey = []
access_token = job['data']['artifactCredentials']['accessKeyId']
sa_key = job['data']['artifactCredentials']['secretAccessKey']
s_Token = job['data']['artifactCredentials']['sessionToken']
configuration = job['data']['actionConfiguration']['configuration']
return(nonce, jobId, inputBucketName, inputObjectKey, outputBucketName, outputObjectKey, access_token, sa_key, s_Token, configuration)