|
4 | 4 |
|
5 | 5 | from pytest_docker_tools import network |
6 | 6 |
|
7 | | -from pytest_celery.vendors.memcached.defaults import CELERY_MEMCACHED_BACKEND |
8 | | -from pytest_celery.vendors.memcached.defaults import * |
| 7 | +from pytest_celery.vendors import MissingCeleryDependency |
9 | 8 | from pytest_celery.vendors.rabbitmq.defaults import CELERY_RABBITMQ_BROKER |
10 | 9 | from pytest_celery.vendors.rabbitmq.defaults import * |
11 | | -from pytest_celery.vendors.redis.backend.defaults import CELERY_REDIS_BACKEND |
12 | | -from pytest_celery.vendors.redis.backend.defaults import * |
13 | | -from pytest_celery.vendors.redis.broker.defaults import CELERY_REDIS_BROKER |
14 | | -from pytest_celery.vendors.redis.broker.defaults import * |
15 | | -from pytest_celery.vendors.redis.defaults import * |
16 | 10 | from pytest_celery.vendors.worker.defaults import CELERY_SETUP_WORKER |
17 | 11 | from pytest_celery.vendors.worker.defaults import * |
18 | 12 |
|
| 13 | +try: |
| 14 | + import pytest_celery.vendors.memcached |
| 15 | +except MissingCeleryDependency: |
| 16 | + _CELERY_MEMCACHED_BACKEND = None |
| 17 | +else: |
| 18 | + from pytest_celery.vendors.memcached.defaults import CELERY_MEMCACHED_BACKEND as _CELERY_MEMCACHED_BACKEND |
| 19 | + from pytest_celery.vendors.memcached.defaults import * |
| 20 | + |
| 21 | + _CELERY_MEMCACHED_BACKEND = None # Beta support at the moment, to be used manually |
| 22 | + |
| 23 | +try: |
| 24 | + import pytest_celery.vendors.redis |
| 25 | +except MissingCeleryDependency: |
| 26 | + _CELERY_REDIS_BACKEND = None |
| 27 | + _CELERY_REDIS_BROKER = None |
| 28 | +else: |
| 29 | + from pytest_celery.vendors.redis.backend.defaults import CELERY_REDIS_BACKEND as _CELERY_REDIS_BACKEND |
| 30 | + from pytest_celery.vendors.redis.backend.defaults import * |
| 31 | + from pytest_celery.vendors.redis.broker.defaults import CELERY_REDIS_BROKER as _CELERY_REDIS_BROKER |
| 32 | + from pytest_celery.vendors.redis.broker.defaults import * |
| 33 | + from pytest_celery.vendors.redis.defaults import * |
| 34 | + |
| 35 | + |
19 | 36 | #################################################################################### |
20 | 37 | # Automatic components |
21 | 38 | #################################################################################### |
|
29 | 46 | # Tests that do not rely on default parametrization will not be affected. |
30 | 47 |
|
31 | 48 | ALL_CELERY_WORKERS = (CELERY_SETUP_WORKER,) |
32 | | -ALL_CELERY_BACKENDS = ( |
33 | | - CELERY_REDIS_BACKEND, |
34 | | - # CELERY_MEMCACHED_BACKEND, # Beta support at the moment, to be used manually |
35 | | -) |
36 | | -ALL_CELERY_BROKERS = ( |
37 | | - CELERY_REDIS_BROKER, |
38 | | - CELERY_RABBITMQ_BROKER, |
39 | | -) |
| 49 | +ALL_CELERY_BACKENDS = (backend for backend in [_CELERY_REDIS_BACKEND, _CELERY_MEMCACHED_BACKEND] if backend is not None) |
| 50 | +ALL_CELERY_BROKERS = (broker for broker in [CELERY_RABBITMQ_BROKER, _CELERY_REDIS_BROKER] if broker is not None) |
40 | 51 |
|
41 | 52 | #################################################################################### |
42 | 53 | # Fixtures |
|
0 commit comments