[GitHub] [airflow] knutole edited a comment on pull request #6722: [AIRFLOW-4922]Fix task get log by Web UI

[GitBox <gi...@apache.org>]

knutole edited a comment on pull request #6722:
URL: https://github.com/apache/airflow/pull/6722#issuecomment-901041426


   We are also getting `No SecretsMasker found!` on Airflow 2.1.2... 
   
   Could this be due to breaking changes in the configuration file? 
   
   We have tried setting `hide_sensitive_var_conn_fields = False` to no avail. 
   
   ```bash
   [2021-08-18 11:05:53,690] {celery_executor.py:120} ERROR - Failed to execute task No SecretsMasker found!.
   Traceback (most recent call last):
     File "/usr/local/lib/python3.6/dist-packages/airflow/executors/celery_executor.py", line 117, in _execute_in_fork
       args.func(args)
     File "/usr/local/lib/python3.6/dist-packages/airflow/cli/cli_parser.py", line 48, in command
       return func(*args, **kwargs)
     File "/usr/local/lib/python3.6/dist-packages/airflow/utils/cli.py", line 91, in wrapper
       return f(*args, **kwargs)
     File "/usr/local/lib/python3.6/dist-packages/airflow/cli/commands/task_command.py", line 212, in task_run
       settings.configure_orm(disable_connection_pool=True)
     File "/usr/local/lib/python3.6/dist-packages/airflow/settings.py", line 224, in configure_orm
       mask_secret(engine.url.password)
     File "/usr/local/lib/python3.6/dist-packages/airflow/utils/log/secrets_masker.py", line 91, in mask_secret
       _secrets_masker().add_mask(secret, name)
     File "/usr/local/lib/python3.6/dist-packages/airflow/utils/log/secrets_masker.py", line 105, in _secrets_masker
       raise RuntimeError("No SecretsMasker found!")
   RuntimeError: No SecretsMasker found!
   [2021-08-18 11:05:53,710: ERROR/ForkPoolWorker-3] Task airflow.executors.celery_executor.execute_command[f6a9b0cd-bb0c-414a-a51c-80579f2d2f1e] raised unexpected: AirflowException('Celery command failed on host: 64c3bc97f173',)
   Traceback (most recent call last):
     File "/usr/local/lib/python3.6/dist-packages/celery/app/trace.py", line 412, in trace_task
       R = retval = fun(*args, **kwargs)
     File "/usr/local/lib/python3.6/dist-packages/celery/app/trace.py", line 704, in __protected_call__
       return self.run(*args, **kwargs)
     File "/usr/local/lib/python3.6/dist-packages/airflow/executors/celery_executor.py", line 88, in execute_command
       _execute_in_fork(command_to_exec)
     File "/usr/local/lib/python3.6/dist-packages/airflow/executors/celery_executor.py", line 99, in _execute_in_fork
       raise AirflowException('Celery command failed on host: ' + get_hostname())
   airflow.exceptions.AirflowException: Celery command failed on host: 64c3bc97f173
   ```
   
   The erroring line is 105 in `_secrets_masker.py`:
   ```python
   @cache
   def _secrets_masker() -> "SecretsMasker":
   
       for flt in logging.getLogger('airflow.task').filters:
           if isinstance(flt, SecretsMasker):
               return flt
       raise RuntimeError("No SecretsMasker found!")  
   ```


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: commits-unsubscribe@airflow.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org