Transport

Transport factory.

class cumin.transport.Transport

Bases: object

Transport factory class.

static new(config, target, logger=None)

Create a transport worker class based on the configuration (factory).

Parameters:

• config (dict) -- the configuration dictionary.
• target (cumin.transports.Target) -- a Target instance.
• logger (logging.Logger, optional) -- an optional logger instance.

Returns:

the created worker instance for the configured transport.

Return type:

BaseWorker

Raises:

• cumin.CuminError -- if the configuration is missing the required transport key.
• exceptions.ImportError -- if unable to import the transport module.
• exceptions.AttributeError -- if the transport module is missing the required worker_class attribute.