Merge pull request #1234 from natefoo/pulsar-missing-param

[15.10] Add the missing "amqp_ack_republish_time" param for the Pulsar runner
galaxyproject · Dec 4, 2015 · 736bf3c · 736bf3c
2 parents 516b079 + 107de0e
commit 736bf3c
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/lib/galaxy/jobs/runners/pulsar.py b/lib/galaxy/jobs/runners/pulsar.py
@@ -69,6 +69,10 @@
         map=specs.to_bool_or_none,
         default=None
     ),
+    amqp_ack_republish_time=dict(
+        map=lambda val: None if val == "None" else int(val),
+        default=None,
+    ),
     amqp_consumer_timeout=dict(
         map=lambda val: None if val == "None" else float(val),
         default=None,