aboutsummaryrefslogtreecommitdiff
path: root/scripts
diff options
context:
space:
mode:
authorFrederick Muriuki Muriithi2023-11-15 09:29:00 +0300
committerFrederick Muriuki Muriithi2023-11-15 09:29:00 +0300
commitaae9d6d988867b9b3edba800857830b48668599c (patch)
treeeb438bb45cea3a63e68e9470afce58b47dd64b4c /scripts
parentfcd4b6fac4296d2b6975e1504dd57d7fc59d3dd5 (diff)
downloadgn-uploader-aae9d6d988867b9b3edba800857830b48668599c.tar.gz
Linting: Fix linting errors.
Diffstat (limited to 'scripts')
-rw-r--r--scripts/insert_data.py4
-rw-r--r--scripts/worker.py1
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):