Marc Lipoff
01/28/2021, 2:31 PMMariia Kerimova
01/28/2021, 2:55 PMfrom prefect.artifacts import create_markdown
from prefect import task, Flow
@task
def get_items():
item = ["one", "two", "three", "four"]
items = []
for i in range(4):
items.append(item)
return items
@task()
def parse_artifact_format(item):
row = "| " + " | ".join(item) + "|\n"
return row
@task(name="Create Table")
def generate_artifact(info_markdown_format):
table = "".join(info_markdown_format)
create_markdown(
f"| Column | Column | Column | Column |\n| ----------- | ----------- | ----------- | ----------- |\n{table}"
)
with Flow(
name="Markdown Flow"
) as flow:
items = get_items()
info_markdown_format = parse_artifact_format.map(items)
generate_artifact(info_markdown_format)
if __name__ == "__main__":
flow.register(project_name="Examples")
# flow.run()
Marc Lipoff
01/28/2021, 2:56 PMCooper Marcus
01/29/2021, 2:02 AM