<s> from celery import chain <EOL> import json <EOL> from genotype_extractor import extract as extract_genotype <EOL> from varcode_annotator import annotate as varcode_genes <EOL> def start_workers_for_vcf_id ( vcf_id ) : <EOL> chain ( extract_genotype . s ( vcf_id ) , varcode_genes . s ( ) ) . delay ( ) <EOL> def restart_failed_tasks ( task_names , vcf_id ) : <EOL> if '<STR_LIT>' in task_names : <EOL> chain ( extract_genotype . s ( vcf_id ) , varcode_genes . s ( ) ) . delay ( ) <EOL> elif '<STR_LIT>' in task_names : <EOL> varcode_genes . s ( vcf_id ) . delay ( ) </s>
