Make airflow/logging_config.py Pylint Compatible (#9672)
This commit is contained in:
Родитель
e4529d18cd
Коммит
78d0287ca7
|
@ -40,7 +40,8 @@ def configure_logging():
|
||||||
logging_config = import_string(logging_class_path)
|
logging_config = import_string(logging_class_path)
|
||||||
|
|
||||||
# Make sure that the variable is in scope
|
# Make sure that the variable is in scope
|
||||||
assert (isinstance(logging_config, dict))
|
if not isinstance(logging_config, dict):
|
||||||
|
raise ValueError("Logging Config should be of dict type")
|
||||||
|
|
||||||
log.info(
|
log.info(
|
||||||
'Successfully imported user-defined logging config from %s',
|
'Successfully imported user-defined logging config from %s',
|
||||||
|
@ -72,7 +73,7 @@ def configure_logging():
|
||||||
return logging_class_path
|
return logging_class_path
|
||||||
|
|
||||||
|
|
||||||
def validate_logging_config(logging_config):
|
def validate_logging_config(logging_config): # pylint: disable=unused-argument
|
||||||
"""Validate the provided Logging Config"""
|
"""Validate the provided Logging Config"""
|
||||||
# Now lets validate the other logging-related settings
|
# Now lets validate the other logging-related settings
|
||||||
task_log_reader = conf.get('logging', 'task_log_reader')
|
task_log_reader = conf.get('logging', 'task_log_reader')
|
||||||
|
|
|
@ -1,5 +1,4 @@
|
||||||
./airflow/configuration.py
|
./airflow/configuration.py
|
||||||
./airflow/logging_config.py
|
|
||||||
./airflow/macros/hive.py
|
./airflow/macros/hive.py
|
||||||
./airflow/migrations/env.py
|
./airflow/migrations/env.py
|
||||||
./airflow/models/crypto.py
|
./airflow/models/crypto.py
|
||||||
|
|
Загрузка…
Ссылка в новой задаче