Commit 07e32d5a authored by BO ZHANG's avatar BO ZHANG 🏀
Browse files

fixed no data bug in filtering

parent 6ff01013
...@@ -88,15 +88,8 @@ class BaseDAG: ...@@ -88,15 +88,8 @@ class BaseDAG:
join_type="inner", join_type="inner",
) )
if len(filtered_data_basis) == 0: if len(filtered_data_basis) == 0:
print(">>> Input plan basis:") return plan_basis[:0], filtered_data_basis
plan_basis.pprint()
print(">>> Input data basis:")
data_basis.pprint()
raise ValueError("No data found for the given pattern.")
u_data_basis = table.unique(filtered_data_basis["dataset", "obs_id"]) u_data_basis = table.unique(filtered_data_basis["dataset", "obs_id"])
if len(u_data_basis) == 0:
filtered_plan_basis = plan_basis[:0]
else:
filtered_plan_basis = table.join( filtered_plan_basis = table.join(
u_data_basis, u_data_basis,
plan_basis, plan_basis,
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment