Fixed broker fixture.

s3rius · s3rius · commit 2e3caf2909d8 · 2022-08-21T15:42:33.000+03:00
Signed-off-by: Pavel Kirilin &lt;win10@list.ru&gt;
diff --git a/taskiq_aio_pika/tests/conftest.py b/taskiq_aio_pika/tests/conftest.py
@@ -177,6 +177,7 @@ async def broker(
         exchange_name=exchange_name,
         queue_name=queue_name,
     )
+    broker.is_worker_process = True
 
     await broker.startup()
 

Original file line number	Diff line number	Diff line change
`@@ -177,6 +177,7 @@ async def broker(`
`177`	`177`	`exchange_name=exchange_name,`
`178`	`178`	`queue_name=queue_name,`
`179`	`179`	`)`
	`180`	`+ broker.is_worker_process = True`
`180`	`181`
`181`	`182`	`await broker.startup()`
`182`	`183`