diff options
Diffstat (limited to 'gn3/commands.py')
| -rw-r--r-- | gn3/commands.py | 19 |
1 files changed, 6 insertions, 13 deletions
diff --git a/gn3/commands.py b/gn3/commands.py index 219f4fd..e5558fe 100644 --- a/gn3/commands.py +++ b/gn3/commands.py @@ -52,25 +52,18 @@ Returns the name of the specific redis hash for the specific task. unique_id = ("cmd::" f"{datetime.now().strftime('%Y-%m-%d%H-%M%S-%M%S-')}" f"{str(uuid4())}") - for key, value in {"cmd": cmd, - "result": "", - "status": "queued"}.items(): - conn.hset(key, value, unique_id) - conn.rpush(job_queue, - unique_id) + for key, value in {"cmd": cmd, "result": "", "status": "queued"}.items(): + conn.hset(name=unique_id, key=key, value=value) + conn.rpush(job_queue, unique_id) if email: - conn.hset("email", - email, - unique_id) + conn.hset(name=unique_id, key="email", value=email) return unique_id def run_cmd(cmd: str) -> Dict: """Run CMD and return the CMD's status code and output as a dict""" - results = subprocess.run(cmd, capture_output=True, - shell=True, check=False) + results = subprocess.run(cmd, capture_output=True, shell=True, check=False) out = str(results.stdout, 'utf-8') if results.returncode > 0: # Error! out = str(results.stderr, 'utf-8') - return {"code": results.returncode, - "output": out} + return {"code": results.returncode, "output": out} |