josh-fell commented on PR #25436:
URL: https://github.com/apache/airflow/pull/25436#issuecomment-1205366750

   > yes the existing flow will through an error if the topic name exists, Now 
I have add `try catch` so before creating the topic just checking if the topic 
exists, if it exists logging it with message and returning the topic name, 
similarly for delete operator
   
   I wonder if there should be a parameter for users to have the option of 
overwriting a topic that might exist. WDYT?
   
   Also, for deleting a topic, if the topic doesn't exist should the task fail? 
Would it be misleading for a task to succeed if the operation is should perform 
does not occur and the user didn't explicitly choose to be indifferent about 
the operation? I could imagine a scenario where users expect to have topics 
deleted when they aren't even though "Airflow says" the deletion task 
succeeded. Just some thoughts.


-- 
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]

Reply via email to