bodspipelines/pipelines/gleif/config.py: Change Kinesis streams

openownership · Sep 13, 2023 · ee63f4e · ee63f4e
1 parent f04b0f2
commit ee63f4e
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/bodspipelines/pipelines/gleif/config.py b/bodspipelines/pipelines/gleif/config.py
@@ -62,7 +62,7 @@
 
 # GLEIF data: Store in Easticsearch and output new to Kinesis stream
 output_new = NewOutput(storage=ElasticStorage(indexes=index_properties),
-                       output=KinesisOutput(stream_name="gleif-dev"))
+                       output=KinesisOutput(stream_name="gleif-prod"))
 
 # Definition of GLEIF data pipeline ingest stage
 ingest_stage = Stage(name="ingest",
@@ -73,7 +73,7 @@
 
 # Kinesis stream of GLEIF data from ingest stage
 gleif_source = Source(name="gleif",
-                      origin=KinesisInput(stream_name="gleif-dev"),
+                      origin=KinesisInput(stream_name="gleif-prod"),
                       datatype=JSONData())
 
 # Elasticsearch indexes for BODS data
@@ -101,7 +101,7 @@ def identify_bods(item):
 
 # BODS data: Store in Easticsearch and output new to Kinesis stream
 bods_output_new = NewOutput(storage=ElasticStorage(indexes=bods_index_properties),
-                            output=KinesisOutput(stream_name="bods-gleif-dev"),
+                            output=KinesisOutput(stream_name="bods-gleif-prod"),
                             identify=identify_bods)
 
 # Definition of GLEIF data pipeline transform stage