fixing s3 sensor missing '/'

TiDeane · Aug 27, 2015 · f62b5bb · f62b5bb
1 parent 696d41c
commit f62b5bb
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/airflow/operators/sensors.py b/airflow/operators/sensors.py
@@ -278,7 +278,7 @@ def __init__(
 
     def poke(self, context):
         hook = hooks.S3Hook(s3_conn_id=self.s3_conn_id)
-        full_url = "s3://" + self.bucket_name + self.bucket_key
+        full_url = "s3://" + self.bucket_name + "/" + self.bucket_key
         logging.info('Poking for key : {full_url}'.format(**locals()))
         if self.wildcard_match:
             return hook.check_for_wildcard_key(self.bucket_key,