taraqueue.testing package

Submodules

taraqueue.testing.compose module

Compose server module.

class taraqueue.testing.compose.ComposeServer(pattern, project='test', env_file=None, compose_files=None, timeout=180, **kwargs)

Bases: ProcessServer

full_name(name)

prepare_func(controldir): Prepare the function to run the compose service.

run(name): Return an ComposeService to the running service.

class taraqueue.testing.compose.ComposeService(name: str, network: str | None = None)

Bases: object

Compose service.

Parameters:

name – Name of the compose service container.
network – Network name to use when resolving the IP address.

property container

property container_id

property env

property ip

name: str

network: str | None = None

property started_at

taraqueue.testing.queue module

Queue fixtures.

taraqueue.testing.queue.memory_queue(): Memory queue fixture.

taraqueue.testing.queue.queue(request): Queue fixture.

taraqueue.testing.queue.redis_queue(redis_service, taraqueue_env_vars): Redis queue fixture.

taraqueue.testing.services module

Service fixtures.

taraqueue.testing.services.redis_client(redis_service, taraqueue_env_vars): Redis client to the service fixture.

taraqueue.testing.services.redis_service(process, taraqueue_env_file, taraqueue_compose_files): Redis service fixture.

taraqueue.testing.services.taraqueue_compose_files(request): Use the compose files from the project - not this library.

taraqueue.testing.services.taraqueue_env_file(taraqueue_env_vars, request)

Environment file containing taraqueue_env_vars.

Cached for troubleshooting purposes.

taraqueue.testing.services.taraqueue_env_vars(): Environment variables for the services.

Module contents