forked from pool/python-celery-batches
* Support passing multiple or keyword arguments by disabling
Celery's ``typing`` feature for ``Batches`` tasks.
* Support |using a custom Request class|_ for ``Batches``
tasks.
* Support calling tasks with an ``eta`` or ``countdown``
specified.
* Handle "hybrid" messages that have moved between Celery
versions.
* Fix task ETA issues when timezone is defined in
configuration.
* Simplify tests.
* Improve PyPI metadata.
* Update README badges to include PyPI and GitHub Actions
* Update copyright information.
* Document use-cases and include more examples.
* Run the unit tests against RabbitMQ & Redis brokers/backends.
* Run `black <https://black.readthedocs.io/>`_, `isort
<https://pycqa.github.io/isort/>`_,
* `flake8 <https://flake8.pycqa.org>`_, `pyupgrade
<https://github.com/asottile/pyupgrade>`_,
* Fix a bug when passing a ``request`` to ``mark_as_done`` with
Celery 5.1.0.
* Clean-up and re-organize code.
* Support Celery 5.2.
* Drop support for Python 3.6.
* Support Python 3.10.
OBS-URL: https://build.opensuse.org/package/show/devel:languages:python/python-celery-batches?expand=0&rev=11
19 lines
661 B
Diff
19 lines
661 B
Diff
Index: celery-batches-0.7/t/integration/test_batches.py
|
|
===================================================================
|
|
--- celery-batches-0.7.orig/t/integration/test_batches.py
|
|
+++ celery-batches-0.7/t/integration/test_batches.py
|
|
@@ -6,11 +6,13 @@ from celery_batches import Batches, Simp
|
|
|
|
from celery import Celery, signals, states
|
|
from celery.app.task import Task
|
|
+from celery.contrib.pytest import *
|
|
from celery.contrib.testing.tasks import ping
|
|
from celery.contrib.testing.worker import TestWorkController
|
|
from celery.result import allow_join_result
|
|
from celery.worker.request import Request
|
|
|
|
+
|
|
import pytest
|
|
|
|
from .tasks import add, cumadd
|