Add env to start process for tfv

helm-charts/templates/configmap.yml

@@ -4,6 +4,7 @@ metadata:
   name: {{ .Values.k8sGroupId }}-{{ .Values.k8sName }}-{{ .Values.k8sEnvironment}}-config
   namespace: memobase
 data:
+  TFV_ENV: {{ .Values.k8sEnvironment }}
   TFV_KAFKA_SERVER_CONFIGS: {{ .Values.kafkaConfigs }}
   TFV_SFTP_CONFIGS: {{ .Values.sftpConfigs }}
   TFV_TOPIC_NAME: {{ .Values.tfvTopicName }}

import_api_app/__init__.py

@@ -46,6 +46,7 @@ def create_app():
         app.config['tfv-sftp-configs'] = os.environ['TFV_SFTP_CONFIGS']
         app.config['tfv-topic-name'] = os.environ['TFV_TOPIC_NAME']
         app.config['tfv-reporting-topic-name'] = os.environ['TFV_REPORTING_TOPIC_NAME']
+        app.config['tfv-env'] = os.environ['TFV_ENV']
 
         app.config['SWAGGER'] = {
             'title': 'Memobase Import API',

import_api_app/resources/ImportProcessStart.py

@@ -53,7 +53,9 @@ class ImportProcessStart(Resource):
                 'kafkaConfigs': current_app.config['tfv-kafka-configs'],
                 'sftpConfigs': current_app.config['tfv-sftp-configs'],
                 'topicName': current_app.config['tfv-topic-name'],
-                'reportingTopicName': current_app.config['tfv-reporting-topic-name']}
+                'reportingTopicName': current_app.config['tfv-reporting-topic-name'],
+                'env': current_app.config['tfv-env']
+                }
 
         if 'xmlRecordTag' in job_parameters:
             body['xmlRecordTag'] = job_parameters['xmlRecordTag']