diff --git a/bodspipelines/pipelines/gleif/config.py b/bodspipelines/pipelines/gleif/config.py index 9a1b944..c1ddf86 100644 --- 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