bugfix: remove remaining references to Event model/views/etc

tapis-project · Oct 12, 2023 · d79d1c0 · d79d1c0
1 parent d0efd9c
commit d79d1c0
Show file tree

Hide file tree

Showing 5 changed files with 3 additions and 8 deletions.
diff --git a/src/api/src/backend/helpers/PipelineDispatchRequestBuilder.py b/src/api/src/backend/helpers/PipelineDispatchRequestBuilder.py
@@ -15,7 +15,6 @@ def build(
         base_url,
         group,
         pipeline,
-        event,
         commit=None,
         directives=None,
         params={}
@@ -97,7 +96,6 @@ def build(
         ]
 
         request["meta"]["origin"] = base_url # Origin of the request
-        request["meta"]["event"] = model_to_dict(event)
 
         request["pipeline_run"] = {}
 

diff --git a/src/api/src/backend/tests/tests_urls.py b/src/api/src/backend/tests/tests_urls.py
@@ -2,7 +2,7 @@
 from django.urls import reverse, resolve
 from backend.views import (
     AddPipelineArchive, Auth, Archives, ChangePipelineOwner, CreateTaskExecution,
-    Credentials, Destinations, Events, Groups, HealthCheck, Identities,
+    Credentials, Destinations, Groups, HealthCheck, Identities,
     ListPipelineArchives, PipelineRuns, Pipelines, RemovePipelineArchive,
     TaskExecutions, Tasks, UpdatePipelineRunStatus, UpdateTaskExecutionStatus,
     Users, RunPipelineWebhook
@@ -33,7 +33,6 @@
     "addPipelineArchive": AddPipelineArchive,
     "removePipelineArchive": RemovePipelineArchive,
     "runPipelineWebhook": RunPipelineWebhook,
-    "event": Events,
     "pipelineRuns": PipelineRuns,
     "pipelineRun": PipelineRuns,
     "updatePipelineRunStatus": UpdatePipelineRunStatus,

diff --git a/src/api/src/backend/views/Nuke.py b/src/api/src/backend/views/Nuke.py
@@ -1,7 +1,7 @@
 from backend.views.RestrictedAPIView import RestrictedAPIView
 from backend.views.http.responses.BaseResponse import BaseResponse
 from backend.services.SecretService import service as secret_service
-from backend.models import Task, Identity, Credentials, Context, Destination, Group, GroupUser, Event, Pipeline
+from backend.models import Task, Identity, Credentials, Context, Destination, Group, GroupUser, Pipeline
 
 models = [
     Task,
@@ -11,7 +11,6 @@
     Destination,
     Group,
     GroupUser,
-    Event,
     Pipeline
 ]
 

diff --git a/src/api/src/backend/views/RunPipeline.py b/src/api/src/backend/views/RunPipeline.py
@@ -15,7 +15,7 @@
 from backend.services.PipelineDispatcher import service as pipeline_dispatcher
 from backend.services.GroupService import service as group_service
 from backend.services.SecretService import service as secret_service
-from backend.models import Event, Pipeline
+from backend.models import  Pipeline
 
 
 request_builder = PipelineDispatchRequestBuilder(secret_service)

diff --git a/src/engine/src/owe_python_sdk/TaskExecutor.py b/src/engine/src/owe_python_sdk/TaskExecutor.py
@@ -27,7 +27,6 @@ def __init__(self, task, ctx, exchange: EventExchange, plugins=[]):
         self.task = task
         self.pipeline = self.ctx.pipeline
         self.group = self.ctx.group
-        self.event = self.ctx.meta.event
         self.directives = self.ctx.directives
         self.polling_interval = DEFAULT_POLLING_INTERVAL
         self._resources: list[Resource] = []