From 9c7d1343a9244c2eb40c5b581e17db5f95e8439f Mon Sep 17 00:00:00 2001 From: Ludovic DEHON Date: Sun, 19 Feb 2023 22:41:55 +0100 Subject: [PATCH] cleanup --- cli/src/test/resources/application.yml | 4 ++++ .../memory/MemoryFlowTopologyRepository.java | 22 +++++++++++++++++++ 2 files changed, 26 insertions(+) create mode 100644 repository-memory/src/main/java/io/kestra/repository/memory/MemoryFlowTopologyRepository.java diff --git a/cli/src/test/resources/application.yml b/cli/src/test/resources/application.yml index 2f773311a19..323a4a5101e 100644 --- a/cli/src/test/resources/application.yml +++ b/cli/src/test/resources/application.yml @@ -7,6 +7,10 @@ kestra: type: memory queue: type: memory + storage: + type: local + local: + base-path: /tmp/unittest plugins: path: /tmp/plugins repositories: diff --git a/repository-memory/src/main/java/io/kestra/repository/memory/MemoryFlowTopologyRepository.java b/repository-memory/src/main/java/io/kestra/repository/memory/MemoryFlowTopologyRepository.java new file mode 100644 index 00000000000..8c34f8dd88d --- /dev/null +++ b/repository-memory/src/main/java/io/kestra/repository/memory/MemoryFlowTopologyRepository.java @@ -0,0 +1,22 @@ +package io.kestra.repository.memory; + +import io.kestra.core.models.topologies.FlowTopology; +import io.kestra.core.repositories.FlowTopologyRepositoryInterface; +import jakarta.inject.Singleton; + +import java.util.List; + +@Singleton +@MemoryRepositoryEnabled +public class MemoryFlowTopologyRepository implements FlowTopologyRepositoryInterface { + + @Override + public List findByFlow(String namespace, String flowId, Boolean destinationOnly) { + throw new UnsupportedOperationException(); + } + + @Override + public FlowTopology save(FlowTopology flowTopology) { + throw new UnsupportedOperationException(); + } +}