From e051a53591905ef5e7a20ac2639f9f70ff6f9aaf Mon Sep 17 00:00:00 2001 From: Girum Bizuayehu Date: Fri, 17 Oct 2025 18:56:15 +0300 Subject: [PATCH] Fix TypeError: cannot unpack non-iterable Output object --- pipelines/assets/fixtures.py | 12 ++++-------- pipelines/assets/wealth_characteristic.py | 6 +----- 2 files changed, 5 insertions(+), 13 deletions(-) diff --git a/pipelines/assets/fixtures.py b/pipelines/assets/fixtures.py index 431335c..20a9f59 100644 --- a/pipelines/assets/fixtures.py +++ b/pipelines/assets/fixtures.py @@ -382,12 +382,7 @@ def consolidated_fixture( consolidated_instances[model_name] = [] consolidated_instances[model_name] += instances - fixture, metadata = get_fixture_from_instances(consolidated_instances) - - return Output( - fixture, - metadata=metadata, - ) + return get_fixture_from_instances(consolidated_instances) @asset(partitions_def=bss_files_partitions_def) @@ -403,7 +398,8 @@ def uploaded_baselines( Downstream assets apply corrections to the original file and then process the contents to create Communities, Wealth Groups, Livelihood Strategies, etc. """ - fixture, metadata = get_fixture_from_instances(baseline_instances) + output = get_fixture_from_instances(baseline_instances) + fixture = output.value metadata = import_fixture(fixture) # Add the file objects `bss` and `profile_report` FileFields to the model instances @@ -416,7 +412,7 @@ def uploaded_baselines( return Output( None, - metadata=metadata, + metadata=metadata.metadata, ) diff --git a/pipelines/assets/wealth_characteristic.py b/pipelines/assets/wealth_characteristic.py index 034e2a0..3a14207 100644 --- a/pipelines/assets/wealth_characteristic.py +++ b/pipelines/assets/wealth_characteristic.py @@ -543,11 +543,7 @@ def wealth_characteristic_fixture( """ Django fixture for the Livelihood Activities from a BSS. """ - fixture, metadata = get_fixture_from_instances(wealth_characteristic_valid_instances) - return Output( - fixture, - metadata=metadata, - ) + return get_fixture_from_instances(wealth_characteristic_valid_instances) @asset(partitions_def=bss_instances_partitions_def)