New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
TMP TEST #8939
base: main
Are you sure you want to change the base?
Conversation
…rl in each consumer obj
2c5147d
to
fff2521
Compare
aeb6c83
to
c3cf350
Compare
…, also, run with: tox -e "3.12-smoke" -- -k test_blm_348 --reruns 0
) | ||
url=w.app.conf.broker_url.split(';')[0] | ||
), | ||
self.instantiate( |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
registers to event loop
|
||
def start(self, parent): | ||
if self.obj: | ||
if isinstance(self.obj, list): |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
self.obj == c on line 257
if self.obj: | ||
if isinstance(self.obj, list): | ||
from threading import Thread | ||
y = Thread(target=self.obj[0].start) |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
consumer is blocking
@@ -158,7 +158,7 @@ def on_close(self): | |||
|
|||
def on_stopped(self): | |||
self.timer.stop() | |||
self.consumer.shutdown() | |||
self.consumer[0].shutdown() |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
just to make it compile
@@ -222,7 +222,7 @@ def create(self, w): | |||
prefetch_count = max(w.max_concurrency, 1) * w.prefetch_multiplier | |||
else: | |||
prefetch_count = w.concurrency * w.prefetch_multiplier | |||
c = w.consumer = self.instantiate( | |||
c = w.consumer = [self.instantiate( |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
we also discussed maybe to test with consumermixin having 2 consumers with different URLs and then debugging. its not used in a worker but is a smaller case to find race conditions and fix kombu.hub and other components that may be failing eg amqp transport frame
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
.
!!! DO NOT MERGE !!!
Testing if something works in the CI or not due to using Mac as a local dev machine where it does work.