Skip to content

Celery 3.1.23 requires celerytest tweaks #12

@twall

Description

@twall

Found a few issues when attempting to run a threaded worker.

  • Call to Worker.run() should be replaced by Worker.start(). Likely a change in the Celery Worker API?

  • setup_celery_worker seems to override any existing app settings, rather than just updating the ones relevant to threaded operation.

  • Celery memory backend has a bug in a base method passed two arguments but the implementation takes one. Workaround:

    from kombu.transport.base import Transport
    Transport.register_with_event_loop = lambda _args, *_kwargs: 1

  • Memory broker doesn't seem to work. Haven't tracked this down, currently using an AMQP broker instead.

Metadata

Metadata

Assignees

No one assigned

    Labels

    No labels
    No labels

    Type

    No type

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions