This is an automated email from the ASF dual-hosted git repository.
potiuk 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 643f3c3 fix: AwsGlueJobOperator change order of args for load_file
(#16216)
643f3c3 is described below
commit 643f3c35a6ba3def40de7db8e974c72e98cfad44
Author: Avocadomaster <[email protected]>
AuthorDate: Sun Jun 13 02:13:22 2021 +0200
fix: AwsGlueJobOperator change order of args for load_file (#16216)
---
airflow/providers/amazon/aws/operators/glue.py | 6 +++++-
1 file changed, 5 insertions(+), 1 deletion(-)
diff --git a/airflow/providers/amazon/aws/operators/glue.py
b/airflow/providers/amazon/aws/operators/glue.py
index 2544579..646e604 100644
--- a/airflow/providers/amazon/aws/operators/glue.py
+++ b/airflow/providers/amazon/aws/operators/glue.py
@@ -101,7 +101,11 @@ class AwsGlueJobOperator(BaseOperator):
if self.script_location and not
self.script_location.startswith(self.s3_protocol):
s3_hook = S3Hook(aws_conn_id=self.aws_conn_id)
script_name = os.path.basename(self.script_location)
- s3_hook.load_file(self.script_location, self.s3_bucket,
self.s3_artifacts_prefix + script_name)
+ s3_hook.load_file(
+ filename=self.script_location,
+ key=self.s3_artifacts_prefix + script_name,
+ bucket_name=self.s3_bucket,
+ )
glue_job = AwsGlueJobHook(
job_name=self.job_name,
desc=self.job_desc,
