@transform( annotateCapseqComposition, suffix( ".composition"), ".composition.load" )
def loadCapseqComposition( infile, outfile ):
    track= P.snip( os.path.basename(infile), ".composition").replace(".cleaned","").replace(".","_").replace("-","_")
    statement = """cat %(infile)s | python ~/src/csv2db.py
                         --database=%(database)s
                         --table=%(track)s_composition 
                         --index=gene_id
                 > %(outfile)s; """
    P.run()

############################################################
Local pause implementation of TaskQueueService.PauseQueue.
dataset/ETHPy150Open CGATOxford/cgat/obsolete/pipeline_proj007.py/loadCapseqComposition--crossover with--dataset/ETHPy150Open AppScale/appscale/AppServer/google/appengine/api/taskqueue/taskqueue_stub.py/TaskQueueServiceStub._Dynamic_PauseQueue