You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Right now, the BaseConsumer class is prepared to handle only one action. It is possible that in the near future we will have to consume from multiple queues and therefore perform different actions accordingly.
There are at least two options, that I can see now, to implement this:
Use the ConsumerMixin as a Consumer runner which contains different ConcreteConsumers for different use cases like JobStatus, WorkflowLogs, FilePullStatus. For doing this there might be a limitation since by default ConsumerMixin uses the kombu.Consumer class, see here, so we might need to reimplement it.
The text was updated successfully, but these errors were encountered:
Right now, the
BaseConsumer
class is prepared to handle only one action. It is possible that in the near future we will have to consume from multiplequeue
s and therefore perform different actions accordingly.There are at least two options, that I can see now, to implement this:
Follow how Celery uses
kombu.ConsumerMixin
, which can be seen here. Basically, theConsumerMixin
class takes a mapping with the different types of messages and the different actions, so depending on the message type a concrete function is calledUse the
ConsumerMixin
as a Consumer runner which contains differentConcreteConsumer
s for different use cases likeJobStatus
,WorkflowLogs
,FilePullStatus
. For doing this there might be a limitation since by defaultConsumerMixin
uses thekombu.Consumer
class, see here, so we might need to reimplement it.The text was updated successfully, but these errors were encountered: