Skip to content

Commit b3594d1

Browse files
Update pipeline_file_loader.py
1 parent 466466a commit b3594d1

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

nodestream/pipeline/pipeline_file_loader.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -52,7 +52,7 @@ class PipelineInitializationArguments:
5252
annotations: Optional[List[str]] = None
5353
on_effective_configuration_resolved: Optional[Callable[[List[Dict]], None]] = None
5454
extra_steps: Optional[List[Step]] = None
55-
effecitve_config_values: Optional[ScopeConfig] = None
55+
effective_config_values: Optional[ScopeConfig] = None
5656
object_store: ObjectStore = field(default_factory=ObjectStore.null)
5757

5858
@classmethod
@@ -145,7 +145,7 @@ def __init__(self, step_definitions: List[StepDefinition]) -> None:
145145
self.step_definitions = step_definitions
146146

147147
def initialize_with_arguments(self, init_args: PipelineInitializationArguments):
148-
with set_config(init_args.effecitve_config_values):
148+
with set_config(init_args.effective_config_values):
149149
steps_defined_in_file = [
150150
step_definition.load_step()
151151
for step_definition in self.step_definitions

0 commit comments

Comments
 (0)