Are you using Cloud Functions for event based processing ?

dag.py

def files_processor():

    wait_for_objects_task = MultipleGcsBucketSensor(
        task_id='wait_for_objects',
        buckets=['sandbox-mdjohossou-first-bucket', 'sandbox-mdjohossou-second-bucket']
    )

    process_objects_task = PythonOperator(
        task_id='process_objects',
        python_callable=process_objects,
        provide_context=True
    )

    trigger_files_processor_dag_task = TriggerDagRunOperator(
        task_id='trigger_files_processor_dag',
        trigger_dag_id='files_processor'
    )

    wait_for_objects_task >> process_objects_task >> trigger_files_processor_dag_task