aztk/node_scripts/scheduling/submit.py
def receive_submit_request(application_file_path):
    """
        Handle the request to submit a task
    """
    blob_client = config.blob_client
    application = common.load_application(application_file_path)

    cmd = __app_submit_cmd(application)
    exit_code = -1
    try:
        exit_code = subprocess.call(cmd.to_str(), shell=True)
        common.upload_log(blob_client, application)
    except Exception as e:
        common.upload_error_log(str(e), os.path.join(os.environ["AZ_BATCH_TASK_WORKING_DIR"], "application.yaml"))
    return exit_code

        Handle the request to submit a task
    
Handle the request to submit a task
Handle the request to submit a task
def receive_submit_request(application_file_path):
    blob_client = config.blob_client
    application = common.load_application(application_file_path)
    cmd = __app_submit_cmd(application)
    exit_code = -1
    try:
        exit_code = subprocess.call(cmd.to_str(), shell=True)
        common.upload_log(blob_client, application)
    except Exception as e:
        common.upload_error_log(str(e), os.path.join(os.environ["AZ_BATCH_TASK_WORKING_DIR"], "application.yaml"))
    return exit_code
def receive_submit_request ( application_file_path ) : blob_client = config . blob_client application = common . load_application ( application_file_path ) cmd = __app_submit_cmd ( application ) exit_code = - 1 try : exit_code = subprocess . call ( cmd . to_str ( ) , shell = True ) common . upload_log ( blob_client , application ) except Exception as e : common . upload_error_log ( str ( e ) , os . path . join ( os . environ [ "AZ_BATCH_TASK_WORKING_DIR" ] , "application.yaml" ) ) return exit_code
Handle the request to submit a task
Handle the request to submit a task
"""
        Handle the request to submit a task
    """
application_file_path