Commit 43daf735 authored by BO ZHANG's avatar BO ZHANG 🏀
Browse files

add query_ref_cat

parent f5871d4d
Pipeline #11824 passed with stage
in 0 seconds
...@@ -400,7 +400,7 @@ class Pipeline: ...@@ -400,7 +400,7 @@ class Pipeline:
def ref_cat(self) -> None | str: def ref_cat(self) -> None | str:
"""Final DFS catalog name.""" """Final DFS catalog name."""
task_ref_cat = self.task.get("ref_cat", None) task_ref_cat = self.task.get("ref_cat", None)
if task_ref_cat and task_ref_cat in self.dfs1.catalog.all_catalog_names: if task_ref_cat and task_ref_cat in self.dfs1.catalog.all_catalog_names():
# task specified catalog # task specified catalog
return task_ref_cat return task_ref_cat
else: else:
......
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