Why does Airflow BashOperator fetch multiple days of data when API URL has single-day date range?

[assadali007]

I am learning Apache Airflow and created a simple DAG to fetch daily events from a REST API.When I call the API directly in the browser, it correctly returns one day of data http://localhost:5000/events?start_date=2019-01-01&end_date=2019-01-02
[ { "date": "2019-01-01", "user": "user1" } ]

However, when I call the same API URL using an Airflow BashOperator, the output file contains data from 2019-01-01 to 2019-01-05, which is unexpected.
`dag = DAG(
dag_id="04_time_delta",
schedule_interval='@daily',
start_date=dt.datetime(2026,1,1)
)

fetch_events = BashOperator(
task_id ='fetch_events',
bash_command=(
"mkdir -p /Users/asadali/data/events && "
"curl -o /Users/asadali/data/events/events.json http://localhost:5000/events?"
"start_date=2019-01-01&"
"end_date=2019-01-02"
),
dag = dag
)


`

fetch_events

[potiuk]

Single & in bash is causing the command to go in background. You need to quote your command properly. You need to understand bash evaluation mechanism when you pass commands to bash.

[assadali007]

i am not understand please try to understand me simple English language i am reading book on this book example look like this `fetch_events = BashOperator(
task_id="fetch_events",
bash_command=(
"mkdir -p /data && "
"curl -o /data/events.json " "http://localhost:5000/events?"
"start_date=2019-01-01&"
"end_date=2019-01-02"
),
dag=dag,
)

`

[assadali007]

it solve it
fetch_events = BashOperator( task_id="fetch_events", bash_command=( "mkdir -p /Users/asadali/data/events && " "curl -o /Users/asadali/data/events/events.json " "\"http://localhost:5000/events?start_date=2019-01-01&end_date=2019-01-02\"" ), dag=dag )