(airflow) branch main updated: fix(sftp): add return statement to yield within a while loop in triggers (#38391)

[husseinawala]

This is an automated email from the ASF dual-hosted git repository.

husseinawala pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git


The following commit(s) were added to refs/heads/main by this push:
     new 5bf60bcf56 fix(sftp): add return statement to yield within a while 
loop in triggers (#38391)
5bf60bcf56 is described below

commit 5bf60bcf56fb7f2f4ac453216ed487b31cff3b9f
Author: Wei Lee <weilee...@gmail.com>
AuthorDate: Fri Mar 22 18:38:28 2024 +0800

    fix(sftp): add return statement to yield within a while loop in triggers 
(#38391)
---
 airflow/providers/sftp/triggers/sftp.py | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/airflow/providers/sftp/triggers/sftp.py 
b/airflow/providers/sftp/triggers/sftp.py
index 9bb1f289e0..1c117a5a13 100644
--- a/airflow/providers/sftp/triggers/sftp.py
+++ b/airflow/providers/sftp/triggers/sftp.py
@@ -113,14 +113,17 @@ class SFTPTrigger(BaseTrigger):
                                 "message": f"Sensed {len(files_sensed)} files: 
{files_sensed}",
                             }
                         )
+                        return
                 else:
                     mod_time = await hook.get_mod_time(self.path)
                     if _newer_than:
                         mod_time_utc = 
convert_to_utc(datetime.strptime(mod_time, "%Y%m%d%H%M%S"))
                         if _newer_than <= mod_time_utc:
                             yield TriggerEvent({"status": "success", 
"message": f"Sensed file: {self.path}"})
+                            return
                     else:
                         yield TriggerEvent({"status": "success", "message": 
f"Sensed file: {self.path}"})
+                        return
                 await asyncio.sleep(self.poke_interval)
             except AirflowException:
                 await asyncio.sleep(self.poke_interval)