Skip to content

Commit b4bdd25

Browse files
committed
Bugfix
1 parent c2e3bc3 commit b4bdd25

File tree

1 file changed

+3
-4
lines changed

1 file changed

+3
-4
lines changed

operators/mailchimp_to_s3_operator.py

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -132,9 +132,9 @@ def get_all(self, ids, resource):
132132
extra_args=extra_args
133133
)
134134
results += results
135-
135+
136136
return results
137-
137+
138138
def execute(self, context):
139139
"""
140140
Execute the operator.
@@ -191,8 +191,7 @@ def execute(self, context):
191191
# Write the results to a temporary file and save that file to s3.
192192
with NamedTemporaryFile("w") as tmp:
193193
for result in results:
194-
filtered_result = self.filter_fields(result)
195-
tmp.write(json.dumps(filtered_result) + '\n')
194+
tmp.write(json.dumps(result) + '\n')
196195

197196
tmp.flush()
198197

0 commit comments

Comments
 (0)