<h3 dir="auto">Apache Airflow version</h3>
<p dir="auto">Other Airflow 2 version (please specify below)</p>
<h3 dir="auto">What happened</h3>
<p dir="auto">While using the Dynamic Task Mapping the following error is thrown in worker while loading DAG.<br>
Setting task policy for Dag: DAG1 Task: DownstreamDagTrigger<br>
[2023-01-09 09:44:36,545: ERROR/ForkPoolWorker-7] can’t set attribute<br>
Traceback (most recent call last):<br>
File “/home/airflow/.local/lib/python3.8/site-packages/airflow/models/dagbag.py”, line 523, in collect_dags<br>
found_dags = self.process_file(filepath, only_if_updated=only_if_updated, safe_mode=safe_mode)<br>
File “/home/airflow/.local/lib/python3.8/site-packages/airflow/models/dagbag.py”, line 291, in process_file<br>
found_dags = self._process_modules(filepath, mods, file_last_changed_on_disk)<br>
File “/home/airflow/.local/lib/python3.8/site-packages/airflow/models/dagbag.py”, line 407, in _process_modules<br>
self.bag_dag(dag=dag, root_dag=dag)<br>
File “/home/airflow/.local/lib/python3.8/site-packages/airflow/models/dagbag.py”, line 434, in bag_dag<br>
self._bag_dag(dag=dag, root_dag=root_dag, recursive=True)<br>
File “/home/airflow/.local/lib/python3.8/site-packages/airflow/models/dagbag.py”, line 451, in _bag_dag<br>
settings.task_policy(task)<br>
File “/home/airflow/.local/lib/python3.8/site-packages/datahub_provider/_plugin.py”, line 308, in custom_task_policy<br>
task_policy(task)<br>
File “/home/airflow/.local/lib/python3.8/site-packages/datahub_provider/_plugin.py”, line 297, in task_policy<br>
task.on_failure_callback = _wrap_on_failure_callback(task.on_failure_callback)<br>
AttributeError: can’t set attribute<br>
This error is thrown can some please help.</p>
<p dir="auto">I am using the TriggerDagRunOperator for Triggering Multiple Downstream DAG.</p>
<h3 dir="auto">What you think should happen instead</h3>
<p dir="auto">The DAG Dependency Graph should be shown like<br>
<a href="url"></a></p>
<h3 dir="auto">How to reproduce</h3>
<p dir="auto">You can use<br>
TriggerDagRunOperator.partial(<br>
task_id="Task1",<br>
dag=dag,<br>
reset_dag_run=True,<br>
).expand(trigger_dag_id=task_conf.ops_params['downstream_dag'])</p>
<h3 dir="auto">Operating System</h3>
<p dir="auto">Deployed on EKS</p>
<h3 dir="auto">Versions of Apache Airflow Providers</h3>
<p dir="auto">apache-airflow                           2.3.4<br>
apache-airflow-providers-amazon          5.0.0<br>
apache-airflow-providers-apache-hive     4.1.0<br>
apache-airflow-providers-apache-livy     3.1.0<br>
apache-airflow-providers-apache-spark    4.0.0<br>
apache-airflow-providers-celery          3.0.0<br>
apache-airflow-providers-cncf-kubernetes 4.3.0<br>
apache-airflow-providers-common-sql      1.3.1<br>
apache-airflow-providers-docker          3.1.0<br>
apache-airflow-providers-elasticsearch   4.2.0<br>
apache-airflow-providers-ftp             3.1.0<br>
apache-airflow-providers-google          8.3.0<br>
apache-airflow-providers-grpc            3.0.0<br>
apache-airflow-providers-hashicorp       3.1.0<br>
apache-airflow-providers-http            4.0.0<br>
apache-airflow-providers-imap            3.0.0<br>
apache-airflow-providers-microsoft-azure 4.2.0<br>
apache-airflow-providers-mysql           3.2.0<br>
apache-airflow-providers-odbc            3.1.1<br>
apache-airflow-providers-postgres        5.2.0<br>
apache-airflow-providers-redis           3.0.0<br>
apache-airflow-providers-sendgrid        3.0.0<br>
apache-airflow-providers-sftp            4.0.0<br>
apache-airflow-providers-slack           5.1.0<br>
apache-airflow-providers-sqlite          3.2.0<br>
apache-airflow-providers-ssh             3.1.0</p>
<h3 dir="auto">Deployment</h3>
<p dir="auto">Official Apache Airflow Helm Chart</p>
<h3 dir="auto">Deployment details</h3>
<p dir="auto"><em>No response</em></p>
<h3 dir="auto">Anything else</h3>
<p dir="auto"><em>No response</em></p>
<h3 dir="auto">Are you willing to submit PR?</h3>
<ul class="contains-task-list">
<li class="task-list-item"><input type="checkbox" id="" disabled="" class="task-list-item-checkbox"> Yes I am willing to submit a PR!</li>
</ul>
<h3 dir="auto">Code of Conduct</h3>
<ul class="contains-task-list">
<li class="task-list-item"><input type="checkbox" id="" disabled="" class="task-list-item-checkbox" checked=""> I agree to follow this project's <a href="https://github.com/apache/airflow/blob/main/CODE_OF_CONDUCT.md">Code of Conduct</a></li>
</ul>
<h3 dir="auto">Apache Airflow version</h3>
<p dir="auto">2.3.2 (latest released)</p>
<h3 dir="auto">What happened</h3>
<p dir="auto">Using cluster policies, I set a default <code class="notranslate">on_failure_callback</code>.<br>
This works great with all tasks expect with task new task mapping.</p>
<h3 dir="auto">What you think should happen instead</h3>
<p dir="auto">Policies should work on all tasks, including the dynamic mapping or generate an exception with the error.</p>
<h3 dir="auto">How to reproduce</h3>
<p dir="auto">Overwrite any parameters using the <code class="notranslate">task_policy</code>.</p>
<h3 dir="auto">Operating System</h3>
<p dir="auto">Official docker image</p>
<h3 dir="auto">Versions of Apache Airflow Providers</h3>
<p dir="auto"><em>No response</em></p>
<h3 dir="auto">Deployment</h3>
<p dir="auto">Other Docker-based deployment</p>
<h3 dir="auto">Deployment details</h3>
<p dir="auto"><em>No response</em></p>
<h3 dir="auto">Anything else</h3>
<p dir="auto"><em>No response</em></p>
<h3 dir="auto">Are you willing to submit PR?</h3>
<ul class="contains-task-list">
<li class="task-list-item"><input type="checkbox" id="" disabled="" class="task-list-item-checkbox"> Yes I am willing to submit a PR!</li>
</ul>
<h3 dir="auto">Code of Conduct</h3>
<ul class="contains-task-list">
<li class="task-list-item"><input type="checkbox" id="" disabled="" class="task-list-item-checkbox" checked=""> I agree to follow this project's <a href="https://github.com/apache/airflow/blob/main/CODE_OF_CONDUCT.md">Code of Conduct</a></li>
</ul>