From 944374eb0d3c5317584856f22b59bf65a1be14c6 Mon Sep 17 00:00:00 2001 From: Ramin Gharib Date: Tue, 29 Oct 2024 13:13:09 +0100 Subject: [PATCH] Update files --- kpops/components/streams_bootstrap/strimzi_model.py | 2 ++ kpops/pipeline/__init__.py | 1 - .../test_init/test_init_project/config_include_opt.yaml | 3 --- 3 files changed, 2 insertions(+), 4 deletions(-) diff --git a/kpops/components/streams_bootstrap/strimzi_model.py b/kpops/components/streams_bootstrap/strimzi_model.py index d137499ee..fddd3a1c9 100644 --- a/kpops/components/streams_bootstrap/strimzi_model.py +++ b/kpops/components/streams_bootstrap/strimzi_model.py @@ -1,3 +1,5 @@ +from __future__ import annotations + from typing import Optional, Self from pydantic import BaseModel, Field, model_validator diff --git a/kpops/pipeline/__init__.py b/kpops/pipeline/__init__.py index fb5352c80..e7bbf24d3 100644 --- a/kpops/pipeline/__init__.py +++ b/kpops/pipeline/__init__.py @@ -111,7 +111,6 @@ def add_levels(self): ) + 1 ) - for node in nx.topological_sort(self._graph): p = self._component_index.get(node) if p: p.sync_wave = self._graph.nodes[node][sync_wave] diff --git a/tests/cli/snapshots/test_init/test_init_project/config_include_opt.yaml b/tests/cli/snapshots/test_init/test_init_project/config_include_opt.yaml index b5c4385d1..3c86a269a 100644 --- a/tests/cli/snapshots/test_init/test_init_project/config_include_opt.yaml +++ b/tests/cli/snapshots/test_init/test_init_project/config_include_opt.yaml @@ -16,9 +16,6 @@ kafka_connect: kafka_rest: timeout: 30 url: http://localhost:8082/ -operation_mode: !!python/object/apply:builtins.getattr -- !!python/name:kpops.config.OperationMode '' -- HELM pipeline_base_dir: . retain_clean_jobs: false schema_registry: