chore: fix ci failing for avro schemas (#172)

SwissDataScienceCenter · Apr 8, 2024 · 56c725b · 56c725b
1 parent 620fe2e
commit 56c725b
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/components/renku_data_services/message_queue/avro_models/io/renku/events/v1/__init__.py b/components/renku_data_services/message_queue/avro_models/io/renku/events/v1/__init__.py
@@ -5,8 +5,8 @@
 from renku_data_services.message_queue.avro_models.io.renku.events.v1.visibility import Visibility
 from renku_data_services.message_queue.avro_models.io.renku.events.v1.project_authorization_added import ProjectAuthorizationAdded
 from renku_data_services.message_queue.avro_models.io.renku.events.v1.project_removed import ProjectRemoved
-from renku_data_services.message_queue.avro_models.io.renku.events.v1.project_created import ProjectCreated
+from renku_data_services.message_queue.avro_models.io.renku.events.v1.project_updated import ProjectUpdated
 from renku_data_services.message_queue.avro_models.io.renku.events.v1.user_added import UserAdded
 from renku_data_services.message_queue.avro_models.io.renku.events.v1.user_removed import UserRemoved
 from renku_data_services.message_queue.avro_models.io.renku.events.v1.user_updated import UserUpdated
-from renku_data_services.message_queue.avro_models.io.renku.events.v1.project_updated import ProjectUpdated
+from renku_data_services.message_queue.avro_models.io.renku.events.v1.project_created import ProjectCreated
diff --git a/components/renku_data_services/message_queue/generate_models.py b/components/renku_data_services/message_queue/generate_models.py
@@ -126,7 +126,7 @@ def process(self) -> None:
         # sort schemas by dependencies
         keys = list(self.schemas.output_writers.keys())
         keys = sorted(keys)
-        for idx, (record, dependencies) in enumerate(self.record_dependencies.items()):
+        for idx, (record, dependencies) in enumerate(sorted(self.record_dependencies.items())):
             if len(dependencies) == 0:
                 continue
             record_index = keys.index(record)