Task

The Task component of the Genomcore API allows you to get and run children task.

get_task_children

Get all children task from id task withot ‘k’

from genomcore.client import GenomcoreApiClient



api = GenomcoreApiClient(
    token=os.getenv("TOKEN"),
    refresh_token=os.getenv("REFRESH_TOKEN")
)

api.task.get_task_children('12345')

run_child_task

Run children task

from genomcore.client import GenomcoreApiClient



api = GenomcoreApiClient(
    token=os.getenv("TOKEN"),
    refresh_token=os.getenv("REFRESH_TOKEN")
)

tasks=api.task.get_task_children('12345')

for task in child_tasks:

    reserved_parameters = task.reserved_parameters

    binders_presets = { param: presets[param] for param in reserved_parameters }

    task.set_reserved_parameters(binders_presets)

    t = api.task.run_child_task(task)

run_workflow

Run workflow

from genomcore.client import GenomcoreApiClient



api = GenomcoreApiClient(
    token=os.getenv("TOKEN"),
    refresh_token=os.getenv("REFRESH_TOKEN")
)

workflow_data = {
    "task_group":{
        "name":"250912 - Analysis sample muestra002112",
        "workflow":{
            "idworkflow":402
        }
    },
    "tasks":{
        "parent":{
            "version":{
                "slug":"multiannotation_header_pgx_v0_0_1"
            },
            "priority":{
                "idpriority":3
            },
            "binders":[
                "task_000"
            ],
            "parameters":[
                {
                "name":"input",
                "value":"68c42a89e0897da1ce70468b"
                },
                {
                "name":"output-dir",
                "value":"/Datos Genotipado/02 - Anotados/muestra002112"
                },
                {
                "name":"bundle",
                "value":"hg38_v1"
                }
            ]
        },
        "task_000":{
            "version":{
                "slug":"bundle_vep_annotator_v0_0_3"
            },
            "priority":{
                "idpriority":3
            },
            "binders":[

            ],
            "parameters":[
                {
                "name":"vep-cache-type",
                "value":"ensembl"
                }
            ]
        },

    }
tasks=api.task.run_workflow(task_group_data=workflow_data, idproject=123)