whylogs_container.whylabs.logger package

Submodules

whylogs_container.whylabs.logger.logger module

class whylogs_container.whylabs.logger.logger.ContainerLoggerFactory(config_instance: ConfigInstance)

Bases: ThreadLoggerFactory

create_logger(dataset_id: str, options: LoggerOptions) → ThreadRollingLogger

class whylogs_container.whylabs.logger.logger.ContainerProcessRollingLogger(aggregate_by: ~whylogs.api.logger.experimental.logger.actor.time_util.TimeGranularity = TimeGranularity.Day, write_schedule: ~whylogs.api.logger.experimental.logger.actor.time_util.Schedule | None = Schedule(cadence=<TimeGranularity.Minute: 'Minute'>, interval=5), schema: ~whylogs.core.schema.DatasetSchema | None = None, sync_enabled: bool = False, current_time_fn: ~typing.Callable[[], int] | None = None, queue_config: ~whylogs.api.logger.experimental.logger.actor.actor.QueueConfig = QueueConfig(max_batch_size=50000, message_accumualtion_duration=1.0, message_poll_wait=0.1, max_buffer_bytes=100000000), thread_queue_config: ~whylogs.api.logger.experimental.logger.actor.actor.QueueConfig = QueueConfig(max_batch_size=50000, message_accumualtion_duration=1.0, message_poll_wait=0.1, max_buffer_bytes=100000000), writer_factory: ~whylogs.api.logger.experimental.logger.actor.process_rolling_logger.WriterFactory = <whylogs.api.logger.experimental.logger.actor.process_rolling_logger.WhyLabsWriterFactory object>, queue_type: ~whylogs.api.logger.experimental.logger.actor.process_actor.QueueType = QueueType.FASTER_FIFO, logger_factory: ~whylogs.api.logger.experimental.logger.actor.process_rolling_logger.LoggerFactory = <whylogs.api.logger.experimental.logger.actor.process_rolling_logger.ThreadLoggerFactory object>)

Bases: ProcessRollingLogger

is_closed() → bool

whylogs_container.whylabs.logger.logger.create_logger(config_instance: ConfigInstance) → ContainerProcessRollingLogger

Module contents