Update files

bakdata · Oct 29, 2024 · 944374e · 944374e
1 parent a197ea4
commit 944374e
Show file tree

Hide file tree

Showing 3 changed files with 2 additions and 4 deletions.
diff --git 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
@@ -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
@@ -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:
-Original file line number
+Diff line change
@@ Expand Up / @@ -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]
@@ Expand Down @@