env var rename
This commit is contained in:
@ -55,10 +55,10 @@ class LoftService(Base):
|
|||||||
|
|
||||||
def stream_to_s3_bucket(self):
|
def stream_to_s3_bucket(self):
|
||||||
self.file_name = f'{service_helper.key_to_uuid(self.key)}.csv'
|
self.file_name = f'{service_helper.key_to_uuid(self.key)}.csv'
|
||||||
logging.info('Streaming to %s s3 bucket %s', self.file_name, os.environ['MEASURE_PROCESSED_BUCKET'])
|
logging.info('Streaming to %s s3 bucket %s', self.file_name, os.environ['S3_PROCESSED_BUCKET'])
|
||||||
# setup writer buffer and write processed forms to file
|
# setup writer buffer and write processed forms to file
|
||||||
buffer = io.StringIO()
|
buffer = io.StringIO()
|
||||||
solution_file = service_helper.solution_to_file(buffer, self.solver_run.total_form_items, self.solution.forms)
|
solution_file = service_helper.solution_to_file(buffer, self.solver_run.total_form_items, self.solution.forms)
|
||||||
|
|
||||||
# upload generated file to s3 and return result
|
# upload generated file to s3 and return result
|
||||||
return aws_helper.file_stream_upload(solution_file, self.file_name, os.environ['MEASURE_PROCESSED_BUCKET'])
|
return aws_helper.file_stream_upload(solution_file, self.file_name, os.environ['S3_PROCESSED_BUCKET'])
|
||||||
|
Reference in New Issue
Block a user