comparison operation_filter.py @ 6:0427ca314f3d draft default tip

planemo upload for repository https://github.com/galaxyproject/tools-devteam/tree/master/tool_collections/gops/subtract commit d7b1a60c0aecc46b7f625c3e32f882562b512fd9

5:0145969324c4

    if data_params != len(data_param_names):
        for name in data_param_names:
            error_map[name] = "A dataset of the appropriate type is required"


# Commented out by INS, 5/30/2007.  What is the PURPOSE of this?
def exec_after_process(app, inp_data, out_data, param_dict, tool=None, stdout=None, stderr=None):
    """Verify the output data after each run"""
    for data in out_data.values():
        try:
            if stderr and len( stderr ) > 0:
                raise Exception( stderr )
        except Exception:
            data.blurb = JOB_ERROR
            data.state = JOB_ERROR


def exec_after_merge(app, inp_data, out_data, param_dict, tool=None, stdout=None, stderr=None):
    exec_after_process(
        app, inp_data, out_data, param_dict, tool=tool, stdout=stdout, stderr=stderr)

    # strip strand column if clusters were merged
    for data in out_data.values():
        if param_dict['returntype'] is True:
            data.metadata.chromCol = 1
            data.metadata.startCol = 2

        # merge always clobbers strand
        data.metadata.strandCol = None


def exec_after_cluster(app, inp_data, out_data, param_dict, tool=None, stdout=None, stderr=None):
    exec_after_process(
        app, inp_data, out_data, param_dict, tool=tool, stdout=stdout, stderr=stderr)

    # strip strand column if clusters were merged
    if param_dict["returntype"] == '1':
        for data in out_data.values():
            data.metadata.strandCol = None

6:0427ca314f3d

    if data_params != len(data_param_names):
        for name in data_param_names:
            error_map[name] = "A dataset of the appropriate type is required"


def exec_after_merge(app, inp_data, out_data, param_dict, tool=None, stdout=None, stderr=None):
    # strip strand column if clusters were merged
    for data in out_data.values():
        if param_dict['returntype'] is True:
            data.metadata.chromCol = 1
            data.metadata.startCol = 2

        # merge always clobbers strand
        data.metadata.strandCol = None


def exec_after_cluster(app, inp_data, out_data, param_dict, tool=None, stdout=None, stderr=None):
    # strip strand column if clusters were merged
    if param_dict["returntype"] == '1':
        for data in out_data.values():
            data.metadata.strandCol = None