[
https://issues.apache.org/jira/browse/AIRFLOW-4922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17400984#comment-17400984
]
ASF GitHub Bot commented on AIRFLOW-4922:
-----------------------------------------
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
> If a task crashes, host name is not committed to the database so logs aren't
> able to be seen in the UI
> ------------------------------------------------------------------------------------------------------
>
> Key: AIRFLOW-4922
> URL: https://issues.apache.org/jira/browse/AIRFLOW-4922
> Project: Apache Airflow
> Issue Type: Bug
> Components: logging
> Affects Versions: 1.10.3
> Reporter: Andrew Harmon
> Assignee: wanghong-T
> Priority: Major
>
> Sometimes when a task fails, the log show the following
> {code}
> *** Log file does not exist:
> /usr/local/airflow/logs/my_dag/my_task/2019-07-07T09:00:00+00:00/1.log***
> Fetching from:
> http://:8793/log/my_dag/my_task/2019-07-07T09:00:00+00:00/1.log***
> Failed to fetch log file from worker. Invalid URL
> 'http://:8793/log/my_dag/my_task/2019-07-07T09:00:00+00:00/1.log': No host
> supplied
> {code}
> I believe this is due to the fact that the row is not committed to the
> database until after the task finishes.
> https://github.com/apache/airflow/blob/a1f9d9a03faecbb4ab52def2735e374b2e88b2b9/airflow/models/taskinstance.py#L857
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
