Asset Pipeline v2 #145
@ -150,8 +150,7 @@ def get_name_with_task_layer_prefix(name: str) -> str:
|
|||||||
for task_layer_key in constants.TASK_LAYER_TYPES.keys():
|
for task_layer_key in constants.TASK_LAYER_TYPES.keys():
|
||||||
if name.startswith(task_layer_key + "."):
|
if name.startswith(task_layer_key + "."):
|
||||||
return name
|
return name
|
||||||
prefix = asset_pipe.prefix + "." if asset_pipe.prefix != "" else ""
|
return prefix + "." + name
|
||||||
return prefix + name
|
|
||||||
|
|
||||||
|
|
||||||
def get_task_layer_col_name(task_layer_key) -> str:
|
def get_task_layer_col_name(task_layer_key) -> str:
|
||||||
|
Loading…
Reference in New Issue
Block a user