gopidesupavan commented on code in PR #42081: URL: https://github.com/apache/airflow/pull/42081#discussion_r1798141743
########## tests/system/providers/apache/kafka/example_dag_event_listener.py: ########## @@ -26,12 +26,12 @@ # Connections needed for this example dag to finish from airflow.models import Connection +from airflow.providers.apache.kafka.operators.produce import ProduceToTopicOperator +from airflow.providers.apache.kafka.sensors.kafka import AwaitMessageTriggerFunctionSensor # This is just for setting up connections in the demo - you should use standard # methods for setting these connections in production -from airflow.operators.python import PythonOperator -from airflow.providers.apache.kafka.operators.produce import ProduceToTopicOperator -from airflow.providers.apache.kafka.sensors.kafka import AwaitMessageTriggerFunctionSensor +from airflow.providers.standard.core.operators.python import PythonOperator Review Comment: This is not required imports. it is working without try catch. -- 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: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
