lafrite/plesna
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Fix: adapt to new Table form

Browse Source
This commit is contained in:
Bertrand Benjamin 2025-01-03 15:56:29 +01:00
parent e28ab332a7
commit 350c03dbfe
1 changed files with 12 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
tests/compute/test_consume_flux.py
View File

@ -6,12 +6,20 @@ from plesna.models.transformation import Transformation
def test_consume_flux(): def test_consume_flux():
sources = { sources = {
"src1": Table(id="src1", value="here"), "src1": Table(
"src2": Table(id="src2", value="here"), 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 = { targets = {
"tgt1": Table(id="tgt1", value="this"), "tgt1": Table(
"tgt2": Table(id="tgt2", value="that"), 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): def func(sources, targets, **kwrds):