dagster._loggers.colored_console_logger(*args, **kwargs)¶Core class for defining loggers.
Loggers are job-scoped logging handlers, which will be automatically invoked whenever dagster messages are logged from within a job.
logger_fn (Callable[[InitLoggerContext], logging.Logger]) – User-provided function to
instantiate the logger. This logger will be automatically invoked whenever the methods
on context.log are called from within job/pipeline compute logic.
config_schema (Optional[ConfigSchema]) – The schema for the config. Configuration data available in init_context.logger_config. If not set, Dagster will accept any config provided.
description (Optional[str]) – A human-readable description of this logger.
dagster._loggers.json_console_logger(*args, **kwargs)¶Core class for defining loggers.
Loggers are job-scoped logging handlers, which will be automatically invoked whenever dagster messages are logged from within a job.
logger_fn (Callable[[InitLoggerContext], logging.Logger]) – User-provided function to
instantiate the logger. This logger will be automatically invoked whenever the methods
on context.log are called from within job/pipeline compute logic.
config_schema (Optional[ConfigSchema]) – The schema for the config. Configuration data available in init_context.logger_config. If not set, Dagster will accept any config provided.
description (Optional[str]) – A human-readable description of this logger.
dagster.DagsterLogManager(dagster_handler, level=0, managed_loggers=None)[source]¶Centralized dispatch for logging from user code.
Handles the construction of uniform structured log messages and passes them through to the underlying loggers/handlers.
An instance of the log manager is made available to ops as context.log. Users should not
initialize instances of the log manager directly. To configure custom loggers, set the
logger_defs argument in an @job decorator or when calling the to_job() method on a
GraphDefinition.
The log manager inherits standard convenience methods like those exposed by the Python standard
library logging module (i.e., within the body of an op,
context.log.{debug, info, warning, warn, error, critical, fatal}).
The underlying integer API can also be called directly using, e.g.
context.log.log(5, msg), and the log manager will delegate to the log method
defined on each of the loggers it manages.
User-defined custom log levels are not supported, and calls to, e.g.,
context.log.trace or context.log.notice will result in hard exceptions at runtime.
@dagster.logger(config_schema=None, description=None)[source]¶Define a logger.
The decorated function should accept an InitLoggerContext and return an instance of
logging.Logger. This function will become the logger_fn of an underlying
LoggerDefinition.
config_schema (Optional[ConfigSchema]) – The schema for the config. Configuration data available in init_context.logger_config. If not set, Dagster will accept any config provided.
description (Optional[str]) – A human-readable description of the logger.
dagster.LoggerDefinition(logger_fn, config_schema=None, description=None)[source]¶Core class for defining loggers.
Loggers are job-scoped logging handlers, which will be automatically invoked whenever dagster messages are logged from within a job.
logger_fn (Callable[[InitLoggerContext], logging.Logger]) – User-provided function to
instantiate the logger. This logger will be automatically invoked whenever the methods
on context.log are called from within job/pipeline compute logic.
config_schema (Optional[ConfigSchema]) – The schema for the config. Configuration data available in init_context.logger_config. If not set, Dagster will accept any config provided.
description (Optional[str]) – A human-readable description of this logger.
dagster.InitLoggerContext(logger_config, logger_def=None, pipeline_def=None, run_id=None)[source]¶The context object available as the argument to the initialization function of a dagster.LoggerDefinition.
Users should not instantiate this object directly. To construct an
InitLoggerContext for testing purposes, use dagster.
build_init_logger_context().
logger_config¶The configuration data provided by the run config. The
schema for this data is defined by config_schema on the LoggerDefinition
Any
pipeline_def¶The pipeline/job definition currently being executed.
Optional[PipelineDefinition]
logger_def¶The logger definition for the logger being constructed.
Optional[LoggerDefinition]
Example:
from dagster import logger, InitLoggerContext
@logger
def hello_world(init_context: InitLoggerContext):
...
dagster.build_init_logger_context(logger_config=None, pipeline_def=None, job_def=None)[source]¶Builds logger initialization context from provided parameters.
This function can be used to provide the context argument to the invocation of a logger definition.
Note that you may only specify one of pipeline_def and job_def.
logger_config (Any) – The config to provide during initialization of logger.
pipeline_def (Optional[PipelineDefinition]) – The pipeline definition that the logger will be used with.
job_def (Optional[JobDefinition]) – The job definition that the logger will be used with.
Examples
context = build_init_logger_context()
logger_to_init(context)