From 350c03dbfe277820d60a6c9c8a005ae8f3a6d9c6 Mon Sep 17 00:00:00 2001 From: Bertrand Benjamin Date: Fri, 3 Jan 2025 15:56:29 +0100 Subject: [PATCH] Fix: adapt to new Table form --- tests/compute/test_consume_flux.py | 16 ++++++++++++---- 1 file changed, 12 insertions(+), 4 deletions(-) diff --git a/tests/compute/test_consume_flux.py b/tests/compute/test_consume_flux.py index 9255f4d..9422bff 100644 --- a/tests/compute/test_consume_flux.py +++ b/tests/compute/test_consume_flux.py @@ -6,12 +6,20 @@ from plesna.models.transformation import Transformation def test_consume_flux(): sources = { - "src1": Table(id="src1", value="here"), - "src2": Table(id="src2", value="here"), + "src1": Table( + id="src1", repo_id="test", schema_id="test", name="test", value="here" + ), + "src2": Table( + id="src2", repo_id="test", schema_id="test", name="test", value="here" + ), } targets = { - "tgt1": Table(id="tgt1", value="this"), - "tgt2": Table(id="tgt2", value="that"), + "tgt1": Table( + id="tgt1", repo_id="test", schema_id="test", name="test", value="this" + ), + "tgt2": Table( + id="tgt2", repo_id="test", schema_id="test", name="test", value="that" + ), } def func(sources, targets, **kwrds):