Skip to content

Commit 264cb90

Browse files
authored
Merge pull request #8 from vvanglro/develop
fix: docs example
2 parents af40f35 + 8396c11 commit 264cb90

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

README.md

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -71,7 +71,9 @@ taskiq_broker = BrokerWrapper(broker)
7171
# create periodic task
7272
taskiq_broker.task(
7373
message="Hi!",
74-
subject="test-subject"
74+
# If you are using rabbitmq broker, then you need to replace subject with queue.
75+
# If you are using kafka broker, then you need to replace subject with topic.
76+
subject="test-subject",
7577
schedule=[{
7678
"cron": "* * * * *",
7779
}],

0 commit comments

Comments
 (0)