Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
7 changes: 5 additions & 2 deletions .github/workflows/push.yml
Original file line number Diff line number Diff line change
Expand Up @@ -51,7 +51,7 @@ jobs:
- run: pip install ".[all]" --group docs
- run: cd docs && make html

build-unix:
test:
timeout-minutes: 30
strategy:
fail-fast: false
Expand Down Expand Up @@ -94,7 +94,10 @@ jobs:
sudo apt-get update
sudo apt-get remove libhashkit2 libmemcached11 || true
sudo apt-get install -y libmemcached-dev
- run: pip install -e '.[all]' --group test
- run: pip install -e '.[rabbitmq,redis,memcached,prometheus]' --group test
if: ${{ matrix.concurrency == 'cpython' }}
- run: pip install -e '.[rabbitmq,redis,memcached,prometheus,gevent]' --group test
if: ${{ matrix.concurrency == 'gevent' }}
- run: pytest --benchmark-skip
if: ${{ matrix.concurrency == 'cpython' }}
- run: python pytest-gevent.py --benchmark-skip
Expand Down
6 changes: 5 additions & 1 deletion tests/middleware/test_shutdown.py
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,6 @@
import time
from unittest import mock

import gevent
import pytest

import dramatiq
Expand All @@ -13,6 +12,11 @@

from ..common import skip_with_gevent, skip_without_gevent

try:
import gevent
except ImportError:
pass # tests accessing gevent must use @skip_without_gevent

not_supported = threading.current_platform not in threading.supported_platforms


Expand Down
6 changes: 5 additions & 1 deletion tests/middleware/test_time_limit.py
Original file line number Diff line number Diff line change
Expand Up @@ -5,14 +5,18 @@
from unittest import mock

import pytest
from greenlet import getcurrent

import dramatiq
from dramatiq.brokers.stub import StubBroker
from dramatiq.middleware import threading, time_limit

from ..common import skip_with_gevent, skip_without_gevent

try:
from greenlet import getcurrent
except ImportError:
pass # tests using greenlet must use @skip_without_gevent

not_supported = threading.current_platform not in threading.supported_platforms


Expand Down