ephraimbuddy commented on issue #25681:
URL: https://github.com/apache/airflow/issues/25681#issuecomment-1216999341
Task log I saw(just a note for the debugging):
```log
[2022-08-16, 19:22:54 UTC] {taskinstance.py:1561} ERROR - Received SIGTERM.
Terminating subprocesses.
[2022-08-16, 19:22:54 UTC] {taskinstance.py:1909} ERROR - Task failed with
exception
Traceback (most recent call last):
File
"/home/ephraimbuddy/airflow/env/lib/python3.8/site-packages/airflow/models/taskinstance.py",
line 1471, in _run_raw_task
self._execute_task_with_callbacks(context, test_mode)
File
"/home/ephraimbuddy/airflow/env/lib/python3.8/site-packages/airflow/models/taskinstance.py",
line 1575, in _execute_task_with_callbacks
task_orig = self.render_templates(context=context)
File
"/home/ephraimbuddy/airflow/env/lib/python3.8/site-packages/airflow/models/taskinstance.py",
line 2232, in render_templates
rendered_task = self.task.render_template_fields(context)
File
"/home/ephraimbuddy/airflow/env/lib/python3.8/site-packages/airflow/models/mappedoperator.py",
line 724, in render_template_fields
self._resolve_expansion_kwargs(kwargs, template_fields, context, session)
File
"/home/ephraimbuddy/airflow/env/lib/python3.8/site-packages/airflow/decorators/base.py",
line 458, in _resolve_expansion_kwargs
v = self._expand_mapped_field(k, v, context, session=session)
File
"/home/ephraimbuddy/airflow/env/lib/python3.8/site-packages/airflow/models/mappedoperator.py",
line 757, in _expand_mapped_field
all_lengths = self._resolve_map_lengths(context["run_id"],
session=session)
File
"/home/ephraimbuddy/airflow/env/lib/python3.8/site-packages/airflow/models/mappedoperator.py",
line 597, in _resolve_map_lengths
map_lengths = self._get_map_lengths(run_id, session=session)
File
"/home/ephraimbuddy/airflow/env/lib/python3.8/site-packages/airflow/models/mappedoperator.py",
line 570, in _get_map_lengths
TaskMap.task_id.in_(non_mapped_dep_keys),
File
"/home/ephraimbuddy/airflow/env/lib/python3.8/site-packages/sqlalchemy/sql/operators.py",
line 604, in in_
return self.operate(in_op, other)
File
"/home/ephraimbuddy/airflow/env/lib/python3.8/site-packages/sqlalchemy/orm/attributes.py",
line 317, in operate
return op(self.comparator, *other, **kwargs)
File
"/home/ephraimbuddy/airflow/env/lib/python3.8/site-packages/sqlalchemy/sql/operators.py",
line 1386, in in_op
return a.in_(b)
File
"/home/ephraimbuddy/airflow/env/lib/python3.8/site-packages/sqlalchemy/sql/operators.py",
line 604, in in_
return self.operate(in_op, other)
File
"/home/ephraimbuddy/airflow/env/lib/python3.8/site-packages/sqlalchemy/orm/properties.py",
line 431, in operate
return op(self.__clause_element__(), *other, **kwargs)
File
"/home/ephraimbuddy/airflow/env/lib/python3.8/site-packages/sqlalchemy/sql/operators.py",
line 1386, in in_op
return a.in_(b)
File
"/home/ephraimbuddy/airflow/env/lib/python3.8/site-packages/sqlalchemy/sql/operators.py",
line 604, in in_
return self.operate(in_op, other)
File
"/home/ephraimbuddy/airflow/env/lib/python3.8/site-packages/sqlalchemy/sql/elements.py",
line 858, in operate
return op(self.comparator, *other, **kwargs)
File
"/home/ephraimbuddy/airflow/env/lib/python3.8/site-packages/sqlalchemy/sql/operators.py",
line 1386, in in_op
return a.in_(b)
File
"/home/ephraimbuddy/airflow/env/lib/python3.8/site-packages/sqlalchemy/sql/operators.py",
line 604, in in_
return self.operate(in_op, other)
File
"/home/ephraimbuddy/airflow/env/lib/python3.8/site-packages/sqlalchemy/sql/type_api.py",
line 76, in operate
return o[0](self.expr, op, *(other + o[1:]), **kwargs)
File
"/home/ephraimbuddy/airflow/env/lib/python3.8/site-packages/sqlalchemy/sql/default_comparator.py",
line 165, in _in_impl
return _boolean_compare(
File
"/home/ephraimbuddy/airflow/env/lib/python3.8/site-packages/airflow/models/taskinstance.py",
line 1562, in signal_handler
self.task.on_kill()
AttributeError: 'DecoratedMappedOperator' object has no attribute 'on_kill'
[2022-08-16, 19:22:54 UTC] {taskinstance.py:1415} INFO - Marking task as
FAILED. dag_id=bug_test, task_id=do_something_else, map_index=17,
execution_date=20220816T182209, start_date=20220816T182254,
end_date=20220816T182254
[2022-08-16, 19:22:54 UTC] {standard_task_runner.py:92} ERROR - Failed to
execute job 82 for task do_something_else ('DecoratedMappedOperator' object has
no attribute 'on_kill'; 2893)
[2022-08-16, 19:22:54 UTC] {process_utils.py:75} INFO - Process
psutil.Process(pid=2893, status='terminated', exitcode=1, started='19:22:53')
(2893) terminated with exit code 1
```
--
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]
