Merge pull request #195 from tech3371/remove-old-processing-pipeline

Remove old processing pipeline from SIT2
IMAP-Science-Operations-Center · Nov 17, 2023 · 0e02eb3 · 0e02eb3
2 parents 1f6109c + 32c55a8
commit 0e02eb3
Show file tree

Hide file tree

Showing 11 changed files with 0 additions and 563 deletions.
diff --git a/sds_data_manager/lambda_code/SDSCode/indexer.py b/sds_data_manager/lambda_code/SDSCode/indexer.py
@@ -24,8 +24,6 @@
 logging.basicConfig(stream=sys.stdout, level=logging.DEBUG)
 
 s3 = boto3.client("s3")
-# Create a Step Functions client
-step_function_client = boto3.client("stepfunctions")
 
 
 def _load_allowed_filenames():
@@ -246,12 +244,3 @@ def lambda_handler(event, context):
     run_backup(host, region, snapshot_repo_name, snapshot_s3_bucket, snapshot_role_arn)
 
     client.close()
-
-    # Start Step function execution
-    state_machine_arn = os.environ.get("STATE_MACHINE_ARN")
-    input_data = {"instrument": metadata["instrument"]}
-    response = step_function_client.start_execution(
-        stateMachineArn=state_machine_arn,
-        input=json.dumps(input_data),  # Input data must be a JSON string
-    )
-    logger.info(f"Step function execution started: {response}")
diff --git a/sds_data_manager/lambda_images/data_checker_lambda/Dockerfile b/sds_data_manager/lambda_images/data_checker_lambda/Dockerfile
diff --git a/sds_data_manager/lambda_images/data_checker_lambda/data_checker.py b/sds_data_manager/lambda_images/data_checker_lambda/data_checker.py
diff --git a/sds_data_manager/lambda_images/imap_processing_lambda/Dockerfile b/sds_data_manager/lambda_images/imap_processing_lambda/Dockerfile
diff --git a/sds_data_manager/lambda_images/imap_processing_lambda/script.py b/sds_data_manager/lambda_images/imap_processing_lambda/script.py
diff --git a/sds_data_manager/stacks/lambda_stack.py b/sds_data_manager/stacks/lambda_stack.py
diff --git a/sds_data_manager/stacks/sds_data_manager_stack.py b/sds_data_manager/stacks/sds_data_manager_stack.py
@@ -42,7 +42,6 @@ def __init__(
         construct_id: str,
         opensearch: OpenSearch,
         dynamodb_stack: DynamoDB,
-        processing_step_function_arn: str,
         env: cdk.Environment,
         **kwargs,
     ) -> None:
@@ -59,8 +58,6 @@ def __init__(
         dynamodb_stack: DynamoDb
             This class depends on dynamodb_stack, which is built with
             opensearch_stack.py
-        processing_step_function_arn:
-            This has step function arn
         """
         super().__init__(scope, construct_id, env=env, **kwargs)
         # Get the current account number so we can use it in the bucket names
@@ -263,7 +260,6 @@ def __init__(
                 "SNAPSHOT_REPO_NAME": "snapshot-repo",
                 "SECRET_ID": opensearch.secret_name,
                 "REGION": opensearch.region,
-                "STATE_MACHINE_ARN": processing_step_function_arn,
             },
         )