forked from pool/python-celery-batches
Dirk Mueller
8b49d383a1
* 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
|