Something went wrong. Try again.
lol
Something went wrong. Try again.
2.6 kB · 104 lines
Nix
at master
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105{ lib, stdenv, buildPythonPackage, fetchFromGitHub, gevent, pika, prometheus-client, pylibmc, pytestCheckHook, pytest-benchmark, pytest-cov-stub, redis, setuptools, watchdog, watchdog-gevent,}:
buildPythonPackage rec { pname = "dramatiq"; version = "2.0.1"; pyproject = true;
src = fetchFromGitHub { owner = "Bogdanp"; repo = "dramatiq"; tag = "v${version}"; hash = "sha256-VqMHSn2mdkO140t7IpZt32OHoEU0nEXiRWJ0w6Km0o8="; };
build-system = [ setuptools ];
dependencies = [ prometheus-client ];
optional-dependencies = { all = [ gevent pika pylibmc redis watchdog watchdog-gevent ]; gevent = [ gevent ]; memcached = [ pylibmc ]; rabbitmq = [ pika ]; redis = [ redis ]; watch = [ watchdog watchdog-gevent ]; };
nativeCheckInputs = [ pytestCheckHook pytest-cov-stub pytest-benchmark pika redis pylibmc ];
pytestFlags = [ "--benchmark-disable" ];
disabledTests = [ # Requires a running redis "test_after_process_boot_call_has_no_blocked_signals" "test_cli_can_be_reloaded_on_sighup" "test_cli_can_watch_for_source_code_changes" "test_cli_fork_functions_have_no_blocked_signals" "test_consumer_threads_have_no_blocked_signals" "test_middleware_fork_functions_have_no_blocked_signals" "test_redis_broker_can_connect_via_client" "test_redis_broker_can_connect_via_url" "test_redis_process_100k_messages_with_cli" "test_redis_process_10k_fib_with_cli" "test_redis_process_1k_latency_with_cli" "test_worker_threads_have_no_blocked_signals" # Requires a running rabbitmq "test_rabbitmq_broker_can_be_passed_a_list_of_parameters_for_failover" "test_rabbitmq_broker_can_be_passed_a_list_of_uri_for_failover" "test_rabbitmq_broker_can_be_passed_a_semicolon_separated_list_of_uris" "test_rabbitmq_broker_connections_are_lazy" "test_rabbitmq_process_100k_messages_with_cli" "test_rabbitmq_process_10k_fib_with_cli" "test_rabbitmq_process_1k_latency_with_cli" # AssertionError "test_cli_scrubs_stale_pid_files" "test_message_contains_requeue_time_after_retry" ] ++ lib.optionals stdenv.hostPlatform.isDarwin [ # Takes too long for darwin ofborg "test_retry_exceptions_can_specify_a_delay" ];
pythonImportsCheck = [ "dramatiq" ];
meta = { description = "Background Processing for Python 3"; homepage = "https://github.com/Bogdanp/dramatiq"; license = lib.licenses.gpl3Only; maintainers = with lib.maintainers; [ traxys ]; };}