def create_job_document()

in src/jobs_configure.py [0:0]

• 25 lines of code
• 2 McCabe index (conditional complexity)

def create_job_document(jobDocConfig):
    md5sum = jobDocConfig['md5sum']
    fileSize = jobDocConfig['fileSize']
    fileId = jobDocConfig['fileId']
    bucket = jobDocConfig['bucket']
    streamId = jobDocConfig['streamId']

    if 'jobDocPath' in jobDocConfig:
        jobDocPath = jobDocConfig['jobDocPath']
        logging.info("updating job json file %s", jobDocPath)
        with open(jobDocPath, 'rb') as jobDoc:
            data = json.load(jobDoc)
    else:
        logging.info("creating job json")
        data = {}

    data['command'] = 'fota'
    data['streamId'] = streamId
    data['fileId'] = fileId
    data['fileSize'] = fileSize
    data['md5sum'] = md5sum

    with open('job.json', 'w') as outfile:
        json.dump(data, outfile)
        key = 'job' + str(fileId) + '.json'
    s3_interface.upload_file_to_s3('job.json', bucket, key)
    jobDocumentSrc = 'https://{}.s3.amazonaws.com/job{}.json'.format(bucket, str(fileId))
    return jobDocumentSrc