diff options
Diffstat (limited to 'scripts')
| -rw-r--r-- | scripts/insert_data.py | 4 | ||||
| -rw-r--r-- | scripts/worker.py | 1 |
2 files changed, 3 insertions, 2 deletions
diff --git a/scripts/insert_data.py b/scripts/insert_data.py index e1cc29b..c5879ed 100644 --- a/scripts/insert_data.py +++ b/scripts/insert_data.py @@ -153,13 +153,13 @@ def __xref_params__(dbconn: mdb.Connection, means: list[dict]) -> dict: "ProbeSetId": ids[str(mean["ProbeSetId"])] } for mean in means) -def insert_means( +def insert_means(# pylint: disable=[too-many-locals, too-many-arguments] filepath: str, speciesid: int, platform_id: int, datasetid: int, dbconn: mdb.Connection, rconn: Redis) -> int: # pylint: disable=[unused-argument] "Insert the means/averages data into the database" headings = read_file_headings(filepath) strains = strains_info(dbconn, headings[1:], speciesid) - check_strains(headings[1:], strains), + check_strains(headings[1:], strains) probeset_query = ( "INSERT INTO ProbeSet(ChipId, Name) " "VALUES (%(ChipId)s, %(Name)s) ") diff --git a/scripts/worker.py b/scripts/worker.py index 391f522..13556df 100644 --- a/scripts/worker.py +++ b/scripts/worker.py @@ -35,6 +35,7 @@ def update_stdout_stderr(rconn, job_id, bytes_read, stream: str): rconn.hset(name=job_id, key=stream, value=new_contents) def update_status(rconn, job_id, status): + """Update status of job in redis.""" rconn.hset(name=job_id, key="status", value=status) def run_job(job, rconn): |