Skip to content

Commit

Permalink
[pipes] IS_DAGSTER_PIPED_PROCESS -> IS_DAGSTER_PIPES_PROCESS (#17072)
Browse files Browse the repository at this point in the history
We updated the var but not the value.

Can we even do this now that we're past 1.5.0 ?

If we are not aleady past the point of no return we better do this now. 

## How I Tested These Changes

bk
  • Loading branch information
alangenfeld authored Oct 9, 2023
1 parent 4b1ae14 commit e757905
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion python_modules/dagster-pipes/dagster_pipes/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -67,7 +67,7 @@ def _make_message(method: str, params: Optional[Mapping[str, Any]]) -> "PipesMes

# ##### PARAMETERS

IS_DAGSTER_PIPES_PROCESS = "IS_DAGSTER_PIPED_PROCESS"
IS_DAGSTER_PIPES_PROCESS = "IS_DAGSTER_PIPES_PROCESS"

DAGSTER_PIPES_BOOTSTRAP_PARAM_NAMES = {
k: _param_name_to_env_key(k) for k in (IS_DAGSTER_PIPES_PROCESS, "context", "messages")
Expand Down

0 comments on commit e757905

Please sign in to comment.