acoustic-carpenter-78188
04/24/2023, 3:53 AMimport pandas as pd
from flytekit import task, workflow, logger
from flytekit.deck.deck import log_on_deck
from flytekit.image_spec import ImageSpec
new_flytekit = "git+<https://github.com/flyteorg/flytekit@aab764d73871da58847206d868ca94e60242a5b3>"
image_spec = ImageSpec(packages=[new_flytekit],
apt_packages=["git"],
registry="pingsutw",
env={"FLYTE_SDK_LOGGING_LEVEL": "10"})
@task(disable_deck=False, container_image=image_spec)
@log_on_deck
def t1():
print("hello")
print("flyte")
logger.error("error")
logger.warning("warning")
logger.debug("debug")
print("pandas dataframe")
df = pd.DataFrame({"Name": ["Tom", "Joseph"], "Age": [1, 22]})
print(df)
return
@workflow
def wf():
t1()
if __name__ == '__main__':
wf()
image▾