def get_info_for_rj()

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

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

    def get_info_for_rj(self, job_id, *args, **kwargs):
        """
        Get information for RunningJob object.
        """

        data = self.get(job_id, timeout=10)

        file_dependencies = data.get('fileDependencies')

        return {
            'application_name': data.get('applicationName'),
            'archive_location': data.get('archiveLocation'),
            'attachments': data.get('attachments'),
            'client_host': data.get('clientHost'),
            'cluster_id': data.get('executionClusterId'),
            'cluster_name': data.get('executionClusterName'),
            'command_args': data.get('commandArgs'),
            'command_id': data.get('commandId'),
            'command_name': data.get('commandName'),
            'created': data.get('created'),
            'description': data.get('description'),
            'disable_archive': data.get('disableLogArchival'),
            'email': data.get('email'),
            'file_dependencies': file_dependencies.split(',') \
                if file_dependencies is not None else [],
            'finished': data.get('finished'),
            'group': data.get('group'),
            'id': data.get('id'),
            'job_link': data.get('killURI'),
            'json_link': data.get('killURI'),
            'kill_uri': data.get('killURI'),
            'name': data.get('name'),
            'output_uri': data.get('outputURI'),
            'request_data': dict(),
            'setup_file': data.get('envPropFile'),
            'started': data.get('started'),
            'status': data.get('status'),
            'status_msg': data.get('statusMsg'),
            'tags': data.get('tags'),
            'updated': data.get('updated'),
            'user': data.get('user'),
            'version': data.get('version')
        }