Remove flow for refresh.registry.* tasks

Author: dgarros

backend/infrahub/message_bus/operations/refresh/registry.py

@@ -1,4 +1,3 @@
-from prefect import flow
 
 from infrahub import lock
 from infrahub.core.registry import registry
@@ -8,7 +7,6 @@
 from infrahub.worker import WORKER_IDENTITY
 
 
-@flow(name="registry-branch-refresh")
 async def branches(message: messages.RefreshRegistryBranches, service: InfrahubServices) -> None:
     if message.meta and message.meta.initiator_id == WORKER_IDENTITY:
         service.log.info("Ignoring refresh registry refresh request originating from self", worker=WORKER_IDENTITY)
@@ -20,7 +18,6 @@ async def branches(message: messages.RefreshRegistryBranches, service: InfrahubS
     await service.component.refresh_schema_hash()
 
 
-@flow(name="registry-branch-rebase")
 async def rebased_branch(message: messages.RefreshRegistryRebasedBranch, service: InfrahubServices) -> None:
     if message.meta and message.meta.initiator_id == WORKER_IDENTITY:
         service.log.info(

backend/tests/unit/message_bus/test_mappings.py

@@ -18,7 +18,7 @@ def test_message_command_overlap():
 
 @pytest.mark.parametrize(
     "operation",
-    [pytest.param(function, id=key) for key, function in COMMAND_MAP.items()],
+    [pytest.param(function, id=key) for key, function in COMMAND_MAP.items() if not key.startswith("refresh.registry")],
 )
 def test_operations_decorated(operation: Callable):
     if callable(operation) and hasattr(operation, "__name__") and "Flow" not in type(operation).__name__: