Timothy Byrne
09/18/2020, 7:51 PMNuno
09/21/2020, 9:59 AMtask
doesn’t seem to work for class properties. Here is the error:
File "/Users/nuno/Developer/Data-Framework/data-prefect/data_prefect/utils/flows.py", line 67, in factory_flow
flow.fetch()
File "/Users/nuno/Developer/Data-Framework/data-prefect/.venv/lib/python3.8/site-packages/prefect/core/task.py", line 470, in __call__
new.bind(
File "/Users/nuno/Developer/Data-Framework/data-prefect/.venv/lib/python3.8/site-packages/prefect/core/task.py", line 511, in bind
callargs = dict(signature.bind(*args, **kwargs).arguments) # type: Dict
File "/usr/local/Cellar/python@3.8/3.8.5/Frameworks/Python.framework/Versions/3.8/lib/python3.8/inspect.py", line 3025, in bind
return self._bind(args, kwargs)
File "/usr/local/Cellar/python@3.8/3.8.5/Frameworks/Python.framework/Versions/3.8/lib/python3.8/inspect.py", line 2940, in _bind
raise TypeError(msg) from None
TypeError: missing a required argument: 'self'
It seems that I cannot pass the method “self” argument.
Do you guys have any suggestion? Thank you in advance.Joe Schmid
09/22/2020, 3:18 PMKJ
09/25/2020, 10:26 PMKJ
09/25/2020, 10:29 PMAdam
09/30/2020, 11:08 AMJimmy Le
10/21/2020, 2:05 AMtsar
10/24/2020, 10:50 AMale
10/24/2020, 11:02 AMAaron Richter
10/25/2020, 2:42 PMJacob Blanco
10/29/2020, 3:57 AMAshton
11/03/2020, 4:57 PMAdam
11/05/2020, 4:30 PMMartin Donadieu
11/07/2020, 10:18 PMAyush Dattagupta
11/09/2020, 9:55 PMjack clement
11/17/2020, 4:05 PMjack clement
11/17/2020, 4:18 PMGleb Mezhanskiy (Datafold)
11/18/2020, 10:09 AMFelix Vemmer
11/24/2020, 8:23 AMmatta
11/25/2020, 10:40 PMmatta
11/25/2020, 10:42 PMAnna Geller (old account)
12/03/2020, 10:51 AMPedro Martins
01/15/2021, 6:45 PMJeremiah
01/19/2021, 7:51 PMJimmy Le
02/08/2021, 5:28 PMAnna Geller (old account)
02/08/2021, 10:56 PMJim Crist-Harif
02/08/2021, 11:02 PMJeremiah
02/08/2021, 11:03 PMNikolay Vaklinov
02/15/2021, 12:20 PMmatta
02/18/2021, 7:30 PM@task(trigger=all_finished)
def get_filepaths(dbt_path: str = "/root/dbt-repo/target") -> t.List[pathlib.PosixPath]:
return list(pathlib.Path(f"{dbt_path}/compiled").rglob("*.sql"))
def make_query_name(path: pathlib.PosixPath) -> str:
query_name = str(path).split("/compiled")[1]
return f"# {query_name}"
def make_sql_markdown(sql: str) -> str:
return f"
sql\n{sql}\n```"
@task(trigger=all_finished)
def publish_artifact(filepaths: t.List[pathlib.PosixPath]) -> None:
titles_and_queries = [
"\n".join((make_query_name(path), make_sql_markdown(path.read_text())))
for path in filepaths
]
all_merged = "\n\n".join(titles_and_queries)
create_markdown(all_merged)```matta
02/18/2021, 7:30 PM@task(trigger=all_finished)
def get_filepaths(dbt_path: str = "/root/dbt-repo/target") -> t.List[pathlib.PosixPath]:
return list(pathlib.Path(f"{dbt_path}/compiled").rglob("*.sql"))
def make_query_name(path: pathlib.PosixPath) -> str:
query_name = str(path).split("/compiled")[1]
return f"# {query_name}"
def make_sql_markdown(sql: str) -> str:
return f"
sql\n{sql}\n```"
@task(trigger=all_finished)
def publish_artifact(filepaths: t.List[pathlib.PosixPath]) -> None:
titles_and_queries = [
"\n".join((make_query_name(path), make_sql_markdown(path.read_text())))
for path in filepaths
]
all_merged = "\n\n".join(titles_and_queries)
create_markdown(all_merged)```George Coyne
02/18/2021, 7:33 PMDylan
02/18/2021, 7:35 PMale
02/18/2021, 7:48 PM