Skip to content

Commit f085961

Browse files
authored
fix: update deprecated usage of taskiq_redis broker (#169)
1 parent ef52d1c commit f085961

File tree

1 file changed

+2
-4
lines changed
  • fastapi_template/template/{{cookiecutter.project_name}}/{{cookiecutter.project_name}}

1 file changed

+2
-4
lines changed

fastapi_template/template/{{cookiecutter.project_name}}/{{cookiecutter.project_name}}/tkq.py

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -21,13 +21,11 @@
2121
{%- if cookiecutter.enable_rmq == "True" %}
2222
broker = AioPikaBroker(
2323
str(settings.rabbit_url),
24-
{%- if cookiecutter.enable_redis == "True" %}result_backend=result_backend, {%- endif %}
25-
)
24+
){%- if cookiecutter.enable_redis == "True" %}.with_result_backend(result_backend){%- endif %}
2625
{%- elif cookiecutter.enable_redis == "True" %}
2726
broker = ListQueueBroker(
2827
str(settings.redis_url.with_path("/1")),
29-
result_backend=result_backend,
30-
)
28+
).with_result_backend(result_backend)
3129
{%- else %}
3230
broker = ZeroMQBroker()
3331
{%- endif %}

0 commit comments

Comments
 (0)