Get consistent opts for the queued runners
(queue=None, backend=None)
| 225 | |
| 226 | |
| 227 | def __get_queue_opts(queue=None, backend=None): |
| 228 | """ |
| 229 | Get consistent opts for the queued runners |
| 230 | """ |
| 231 | if queue is None: |
| 232 | queue = __opts__.get("runner_queue", {}).get("queue") |
| 233 | if backend is None: |
| 234 | backend = __opts__.get("runner_queue", {}).get("backend", "pgjsonb") |
| 235 | return {"backend": backend, "queue": queue} |
| 236 | |
| 237 | |
| 238 | def insert_runner(fun, args=None, kwargs=None, queue=None, backend=None): |
no test coverage detected