diff --git a/src/api/src/backend/views/ETLPipelines.py b/src/api/src/backend/views/ETLPipelines.py index f0fdd119..a898010b 100644 --- a/src/api/src/backend/views/ETLPipelines.py +++ b/src/api/src/backend/views/ETLPipelines.py @@ -55,13 +55,13 @@ def post(self, request, group_id, *_, **__): print("AFTER GROUP CHECK") # Git repository that contains the pipeline and task definitions for the # tapis etl pipeline - uses = Uses( - name=LATEST_TAPIS_ETL_PIPELINE_TEMPLATE_NAME, - source=GitRepository( - url=TAPIS_ETL_TEMPLATE_REPO_URL, - branch=TAPIS_ETL_TEMPLATE_REPO_BRANCH - ) - ) + uses = Uses(**{ + "name": LATEST_TAPIS_ETL_PIPELINE_TEMPLATE_NAME, + "source": { + "url": TAPIS_ETL_TEMPLATE_REPO_URL, + "branch": TAPIS_ETL_TEMPLATE_REPO_BRANCH + } + }) print("AFTER USES") # Validate the request body based on the type of pipeline specified prepared_request = self.prepare( diff --git a/src/api/src/backend/views/http/requests.py b/src/api/src/backend/views/http/requests.py index fcb3d8d2..8acf3e90 100644 --- a/src/api/src/backend/views/http/requests.py +++ b/src/api/src/backend/views/http/requests.py @@ -526,7 +526,6 @@ class GitRepository(BaseModel): class ClonedGitRepository(GitRepository): directory: str - class Uses(BaseModel): source: GitRepository name: str = None