def submit_job()

in pygenie/adapter/genie_2.py [0:0]

• 20 lines of code
• 7 McCabe index (conditional complexity)

    def submit_job(self, job, **kwargs):
        """Submit a job execution to the server."""

        payload = {
            key: value for key, value in get_payload(job).items() \
            if value is not None \
                and value != [] \
                and value != {} \
                and value != ''
        }

        if payload.get('fileDependencies'):
            payload['fileDependencies'] = ','.join(payload['fileDependencies'])

        logger.debug('payload to genie 2:')
        logger.debug(json.dumps(payload,
                                sort_keys=True,
                                indent=4,
                                separators=(',', ': ')))
        self.call(method='post',
                  url='{}/{}'.format(job._conf.genie.url, Genie2Adapter.JOBS_ENDPOINT),
                  timeout=30,
                  data=json.dumps(payload),
                  headers=JSON_HEADERS)