From 482b6f6ba5d4fe4c2cef314323b88b908db3e1a6 Mon Sep 17 00:00:00 2001 From: Munyoki Kilyungi Date: Tue, 22 Apr 2025 19:27:47 +0300 Subject: Reduce arguments in run_async_cmd by using options dictionary. Signed-off-by: Munyoki Kilyungi --- gn3/commands.py | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) (limited to 'gn3/commands.py') diff --git a/gn3/commands.py b/gn3/commands.py index b4db447..73252a6 100644 --- a/gn3/commands.py +++ b/gn3/commands.py @@ -10,6 +10,7 @@ import tempfile import subprocess from datetime import datetime +from typing import Any from typing import Dict from typing import List from typing import Optional @@ -186,10 +187,12 @@ def compute_job_queue(app: Flask) -> str: def run_async_cmd( conn: Redis, job_queue: str, cmd: Union[str, Sequence[str]], - email: Optional[str] = None, log_level: str = "info", - env: Optional[dict] = None) -> str: + options: Optional[Dict[str, Any]] = None, + log_level: str = "info") -> str: """A utility function to call `gn3.commands.queue_cmd` function and run the worker in the `one-shot` mode.""" + email = options.get("email") if options else None + env = options.get("env") if options else None cmd_id = queue_cmd(conn, job_queue, cmd, email, env) worker_command = [ sys.executable, -- cgit 1.4.1