Skip to content

Commit 22003b3

Browse files
committed
NRL-1411 syntax fix
1 parent d8f37ee commit 22003b3

File tree

1 file changed

+3
-3
lines changed
  • terraform/account-wide-infrastructure/modules/glue/src

1 file changed

+3
-3
lines changed

terraform/account-wide-infrastructure/modules/glue/src/pipeline.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -65,12 +65,12 @@ def extract_dynamic(self):
6565
"""Extract JSON data from S3"""
6666
last_runtime = self.get_last_run()
6767
data = {}
68-
data_source = self.glueContext.getSource("s3", paths=[self.source_path])
68+
data_source = self.glue_context.getSource("s3", paths=[self.source_path])
6969
data_source.setFormat("json")
7070
self.logger.info(f"Extracting data from {self.source_path} as JSON")
7171
for name in self.host_prefixes:
7272
if last_runtime:
73-
data[name] = self.glueContext.create_dynamic_frame.from_options(
73+
data[name] = self.glue_context.create_dynamic_frame.from_options(
7474
connection_type="s3",
7575
connection_options={"paths": [self.source_path], "recurse": True},
7676
format="json",
@@ -80,7 +80,7 @@ def extract_dynamic(self):
8080
)
8181

8282
else:
83-
data[name] = self.glueContext.create_dynamic_frame.from_options(
83+
data[name] = self.glue_context.create_dynamic_frame.from_options(
8484
connection_type="s3",
8585
connection_options={"paths": [self.source_path], "recurse": True},
8686
format="json",

0 commit comments

Comments
 (0)