气流-在函数内使用运算符

我打算在函数内部使用气流运算符，然后从其他任务中调用它。对我来说，任务运行成功，但是并没有触发函数内部的运算符。

def func():
    t1 = BashOperator(
            task_id='print_date',
            bash_command='touch /tmp/aaaaaaaaaaaaa'
        )
    t1

main_dag = DAG(
    'bhuvitest',
    default_args=args,
    description='A simple tutorial DAG',
    schedule_interval=timedelta(days=1),
    catchup=False
)

bhuvitest = PythonOperator(
        task_id='python_task', 
        python_callable=func,
        dag = main_dag)