Use kwargs for auto_release_time (#637)

Signed-off-by: Christian Berendt <berendt@osism.tech>
osism · Oct 26, 2023 · 2914495 · 2914495
1 parent b1dff72
commit 2914495
Showing 1 changed file with 12 additions and 6 deletions.
diff --git a/osism/commands/apply.py b/osism/commands/apply.py
@@ -181,18 +181,24 @@ def handle_role(
                 environment = f"{environment}.{sub}"
             if role.startswith("ceph-"):
                 t = ceph.run.delay(
-                    environment, role[5:], arguments, auto_release_time=task_timeout
+                    environment,
+                    role[5:],
+                    arguments,
+                    {"auto_release_time": task_timeout},
                 )
             else:
                 t = ceph.run.delay(
-                    environment, role, arguments, auto_release_time=task_timeout
+                    environment, role, arguments, {"auto_release_time": task_timeout}
                 )
         elif role == "loadbalancer-ng":
             if sub:
                 environment = f"{environment}.{sub}"
             g = group(
                 kolla.run.si(
-                    environment, playbook, arguments, auto_release_time=task_timeout
+                    environment,
+                    playbook,
+                    arguments,
+                    {"auto_release_time": task_timeout},
                 )
                 for playbook in enums.LOADBALANCER_PLAYBOOKS
             )
@@ -201,7 +207,7 @@ def handle_role(
                     environment,
                     "loadbalancer-ng",
                     arguments,
-                    auto_release_time=task_timeout,
+                    {"auto_release_time": task_timeout},
                 )
                 | g
             ).apply_async()
@@ -221,7 +227,7 @@ def handle_role(
                 kolla_arguments = [f"-e kolla_action={action}"] + arguments
 
             t = kolla.run.delay(
-                environment, role, kolla_arguments, auto_release_time=task_timeout
+                environment, role, kolla_arguments, {"auto_release_time": task_timeout}
             )
         else:
             # Overwrite the environment
@@ -234,7 +240,7 @@ def handle_role(
                 f" {environment} was not found."
             )
             t = ansible.run.delay(
-                environment, role, arguments, auto_release_time=task_timeout
+                environment, role, arguments, {"auto_release_time": task_timeout}
             )
 
         if isinstance(t, GroupResult):