anneadb opened a new issue, #29102:
URL: https://github.com/apache/airflow/issues/29102

   ### Apache Airflow version
   
   2.5.1
   
   ### What happened
   
   I am using dynamic task mapping to process a list of files in the same way.
   The tasks are generated but I cannot see them listed in the UI tab "Mapped 
Tasks".
   When I go to the graph view I can look at the logs for the last run with all 
mapped instances.
   
   <img width="1147" alt="Screenshot 2023-01-23 at 13 07 59" 
src="https://user-images.githubusercontent.com/46241952/214037237-82381300-11c1-43ce-a4b9-b8f16294a74c.png";>
   
   <img width="975" alt="Screenshot 2023-01-23 at 13 08 07" 
src="https://user-images.githubusercontent.com/46241952/214037258-026d4074-40c5-40a1-96de-74c2bd11173f.png";>
   
   
   ### What you think should happen instead
   
   On the tab "Mapped Tasks" I expect to see a list of the generated tasks with 
links to their logs.
   
   ### How to reproduce
   
   * Use a docker-compose with apache/airflow:2.5.1-python3.8 as the base image.
   * Expand a python operator based on a list of file names from another task
   
   Dag code:
   
   ```
   def prep_args(file_name):
       return {"file_name": file_name}
   
   with DAG(
       "imparted_orders_lascana",
       default_args=default_args,
       schedule="19 */3 * * *",
   ) as dag:
   
       t0 = PythonOperator(
           task_id="get_file_list",
           python_callable=get_file_list,
       )
   
       t1 = PythonOperator.partial(
           task_id="transfer_data",
           python_callable=transfer_data,
       ).expand(op_kwargs=t0.output.map(prep_args))
   
   ```
   
   ### Operating System
   
   CentOS 7.9
   
   ### Versions of Apache Airflow Providers
   
   _No response_
   
   ### Deployment
   
   Docker-Compose
   
   ### Deployment details
   
   We're creating our own docker image based on the provided image to add a few 
additional packages.
   
   The webserver config looks like this:
   
   ```
   from __future__ import annotations
   
   import os
   
   from airflow.www.fab_security.manager import AUTH_DB
   
   basedir = os.path.abspath(os.path.dirname(__file__))
   
   # Flask-WTF flag for CSRF
   WTF_CSRF_ENABLED = True
   
   # The authentication type
   # AUTH_DB : Is for database
   AUTH_TYPE = AUTH_DB
   
   # Uncomment and set to desired role to enable access without authentication
   AUTH_ROLE_PUBLIC = "Admin"
   ```
   
   
   ### Anything else
   
   _No response_
   
   ### Are you willing to submit PR?
   
   - [ ] Yes I am willing to submit a PR!
   
   ### Code of Conduct
   
   - [X] I agree to follow this project's [Code of 
Conduct](https://github.com/apache/airflow/blob/main/CODE_OF_CONDUCT.md)
   


-- 
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-unsubscr...@airflow.apache.org.apache.org

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

Reply via email to