Skip to content

Commit

Permalink
args back to params on pipeline. update changelog
Browse files Browse the repository at this point in the history
  • Loading branch information
nathandf committed Oct 11, 2023
1 parent 55c1ced commit b895de1
Show file tree
Hide file tree
Showing 2 changed files with 26 additions and 7 deletions.
20 changes: 20 additions & 0 deletions CHANGELOG.md
Original file line number Diff line number Diff line change
Expand Up @@ -4,6 +4,26 @@ All notable changes to this project will be documented in this file.
The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/),
and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).

## [v1.5.0] - 2023-10-xx

### Breaking Changes
- runPipeline request schema changed. 'params' was changed to 'args'

### Features
- Initial release of the owe-python-sdk. Used in both the workflow engine and Tapis Workflows API
- Added 'params' to Pipeline model - tasks can consume params as inputs
- **Function Tasks**
- Added ability to specify git repositories to clone into the function runtime
- Introduced custom entrypoints
- **Tapis Jobs**
- Implicit inputs for tapis_job tasks that depend on other tapis_job tasks
- **Templating and Inheritence**
- Introduced the template type task
- Added pipeline and task inheritence via the 'uses' property on pipelines and tasks

### non-Breaking Changes
- Refactored Tapis-specific logic from the workflow engine into a Plugin

## [v1.3.1] - 2023-03-29

### Features
Expand Down
13 changes: 6 additions & 7 deletions src/api/src/backend/views/http/requests.py
Original file line number Diff line number Diff line change
Expand Up @@ -285,14 +285,13 @@ class EnvSpec(SpecWithValue):

Env = Dict[str, EnvSpec]

class ParamSpec(SpecWithValue):
type: EnumTaskIOTypes
class ArgSpec(SpecWithValue):
value: Value = None
value_from: ParamSpecValueFrom = None

Params = Dict[str, ParamSpec]
Args = Dict[str, ArgSpec]

PipelineParams = Dict[str, Spec]
Params = Dict[str, Spec]
################## /Common ###################

class S3Auth(BaseModel):
Expand Down Expand Up @@ -456,7 +455,7 @@ class BaseEvent(BaseModel):
username: str = None

class APIEvent(BaseEvent):
params: Params = {}
args: Args = {}
directives: List[str] = None

class WebhookEvent(BaseEvent):
Expand Down Expand Up @@ -697,7 +696,7 @@ class Pipeline(BaseModel):
cron: str = None
archive_ids: List[str] = []
env: Env = {}
params: PipelineParams = {}
params: Params = {}

# NOTE This pre validation transformer is for backwards-compatibility
# Previous pipelines did not have environments or parmas
Expand Down Expand Up @@ -778,7 +777,7 @@ class Group(BaseModel):
class WorkflowSubmissionRequest(BaseModel):
archives: List[Archive] = []
env: Env = {}
params: Params = {}
args: Args = {}
group: Group
pipeline: Pipeline
pipeline_run: PipelineRun
Expand Down

0 comments on commit b895de1

Please sign in to comment.