Jacob Wang
06/22/2023, 8:21 AMimport os
import pathlib
from flytekitplugins.papermill import NotebookTask
from flytekitplugins.awsbatch import AWSBatchConfig
config = AWSBatchConfig(
platformCapabilities="EC2",
)
backtest_wages = NotebookTask(
name="test-notebook",
notebook_path=os.path.join(
pathlib.Path(__file__).parent.parent.absolute(), "notebooks/test-notebook.ipynb"
),
render_deck=True,
task_config=config
)
but got an error:
logger.debug(f"Starting _dispatch_execute for {task_def.name}")
AttributeError: 'function' object has no attribute 'name'
["pyflyte-execute","--inputs","<s3://fiolito-eks-cluster/metadata/propeller/liquidity-forecast-development-alg58fr86fmkgh9nqnf4/n0/data/inputs.pb>","--output-prefix","<s3://fiolito-eks-cluster/metadata/propeller/liquidity-forecast-development-alg58fr86fmkgh9nqnf4/n0/data/0/0>","--raw-output-data-prefix","<s3://fiolito-eks-cluster/99/alg58fr86fmkgh9nqnf4-n0-0>","--resolver","flytekit.core.python_auto_container.default_task_resolver","--","task-module","flytekitplugins.papermill.task","task-name","_dummy_task_func"]
It seems that the _dummy_task_func
is wrong and it comes from:
https://github.com/flyteorg/flytekit/blob/master/plugins/flytekit-papermill/flytekitplugins/papermill/task.py#L145Ketan (kumare3)
Jacob Wang
06/22/2023, 1:54 PMKetan (kumare3)
Kevin Su
06/22/2023, 3:45 PMJacob Wang
06/25/2023, 11:33 AMKetan (kumare3)
Jacob Wang
06/27/2023, 6:54 AMKevin Su
06/27/2023, 7:07 AMSlackbot
06/27/2023, 7:07 AMJacob Wang
06/27/2023, 10:38 AMKevin Su
08/14/2023, 9:37 PMJacob Wang
08/17/2023, 5:48 AM