diff options
| author | Frederick Muriuki Muriithi | 2024-12-03 11:18:14 -0600 |
|---|---|---|
| committer | Frederick Muriuki Muriithi | 2024-12-03 15:11:24 -0600 |
| commit | c7ff9222b74402e068630352ba37de0f15d07b88 (patch) | |
| tree | 61604f01774ff170711df27f99d00ea4a2b3461b /scripts/process_rqtl2_bundle.py | |
| parent | 0c59c583399ff0158d45c0bbdad61a056bd8fd6f (diff) | |
| download | gn-uploader-c7ff9222b74402e068630352ba37de0f15d07b88.tar.gz | |
Pass the redis connection and fully qualified job id
Pass the redis connection on to the function used to build main since it might need to use a connection to redis. Also pass the computed fully qualified job id rather than recomputing it every time. Update dependent functions to take the new arguments.
Diffstat (limited to 'scripts/process_rqtl2_bundle.py')
| -rw-r--r-- | scripts/process_rqtl2_bundle.py | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/scripts/process_rqtl2_bundle.py b/scripts/process_rqtl2_bundle.py index 4efc3e0..8b7a0fb 100644 --- a/scripts/process_rqtl2_bundle.py +++ b/scripts/process_rqtl2_bundle.py @@ -94,7 +94,9 @@ def process_bundle(dbconn: mdb.Connection, if has_geno_file(thejob): logger.info("Processing geno files.") genoexit = install_genotypes( + rconn, dbconn, + f"{rprefix}:{jobid}", argparse.Namespace( speciesid=meta["speciesid"], populationid=meta["populationid"], @@ -110,7 +112,9 @@ def process_bundle(dbconn: mdb.Connection, if has_pheno_file(thejob): phenoexit = install_pheno_files( + rconn, dbconn, + f"{rprefix}:{jobid}", argparse.Namespace( speciesid=meta["speciesid"], platformid=meta["platformid"], |