python_modules/dagster/dagster/core/events/logging.py
def construct_json_event_logger(json_path):
    '''Record a stream of event records to json'''
    check.str_param(json_path, 'json_path')
    return construct_single_handler_logger(
        "json-event-record-logger",
        DEBUG,
        JsonEventLoggerHandler(
            json_path,
            lambda record: construct_event_record(
                StructuredLoggerMessage(
                    name=record.name,
                    message=record.msg,
                    level=record.levelno,
                    meta=record.dagster_meta,
                    record=record,
                )
            ),
        ),
    )
def construct_json_event_logger(json_path):
    '''Record a stream of event records to json'''
    check.str_param(json_path, 'json_path')
    return construct_single_handler_logger(
        "json-event-record-logger",
        DEBUG,
        JsonEventLoggerHandler(
            json_path,
            lambda record: construct_event_record(
                StructuredLoggerMessage(
                    name=record.name,
                    message=record.msg,
                    level=record.levelno,
                    meta=record.dagster_meta,
                    record=record,
                )
            ),
        ),
    )
def construct_json_event_logger ( json_path ) : check . str_param ( json_path , 'json_path' ) return construct_single_handler_logger ( "json-event-record-logger" , DEBUG , JsonEventLoggerHandler ( json_path , lambda record : construct_event_record ( StructuredLoggerMessage ( name = record . name , message = record . msg , level = record . levelno , meta = record . dagster_meta , record = record , ) ) , ) , )
Record a stream of event records to json
Record a stream of event records to json