Skip to content
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

Add events for Flower #81

Open
wants to merge 2 commits into
base: main
Choose a base branch
from
Open

Add events for Flower #81

wants to merge 2 commits into from

Conversation

gersh
Copy link

@gersh gersh commented Aug 2, 2023

Add "task-*" events so we can monitor the queue with Flower.

@gersh gersh requested a review from clokep as a code owner August 2, 2023 18:11
@clokep
Copy link
Owner

clokep commented Aug 2, 2023

Any chance that tests could be added for this?

@gersh
Copy link
Author

gersh commented Aug 2, 2023

Is there a good way to test if a signal has been sent with pytest? I tried:

    class TaskMonitor:
        def __init__(self):
            self.tasks_received = 0
            self.tasks_started = 0
            self.tasks_suceeded = 0

        def on_task_received(self, event):
            self.tasks_received += 1
        def on_task_started(self, event):
            self.tasks_started += 1
        def on_task_suceeded(self, event):
            self.tasks_suceeded += 1

    tm = TaskMonitor()

    recv = celery_app.events.Receiver(connection, handlers={
            'task-received': tm.on_task_received,
            'task-started': tm.on_task_started,
            'task-suceeded': tm.on_task_suceeded,
            '*': tm.on_other
            })

but I can't seem to get it to work. If you can help me figure out how to get it to listen for events in a pytest, I can implement it. I tested it in Flower, and it seems to work, but I'm not sure how to get the internals to work for a unit test.

@clokep
Copy link
Owner

clokep commented Aug 3, 2023

Some of the tests use the SignalCounter class to do this (it is a bit hacky, but I haven't managed to figure out a better way to do it).

@clokep
Copy link
Owner

clokep commented Aug 3, 2023

See also #70.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

None yet

2 participants