Nidhin Nandhakumar
04/17/2023, 8:57 PMclass HubspotIOManager(IOManager):
def __init__(self, token: str) -> None:
pass
def handle_output(self, context: OutputContext, obj: pd.DataFrame):
# Skip handling if the output is None
if obj is None:
return
obj_name = context.asset_key.to_python_identifier()
# do stuff.
# Recording metadata from an I/O manager:
# <https://docs.dagster.io/concepts/io-management/io-managers#recording-metadata-from-an-io-manager>
context.add_output_metadata({ "table_name": table_name})
def load_input(self, context: InputContext):
# upstream_output.asset_key is the asset key given to the Out that we're loading for
pass
owen
04/17/2023, 9:33 PM<http://context.log.info|context.log.info>("hi")
inside handle_output/load_input should work -- do you mind sharing the full stack trace?Nidhin Nandhakumar
04/17/2023, 10:17 PMNidhin Nandhakumar
04/17/2023, 10:17 PMowen
04/17/2023, 10:20 PMget_dagster_logger().info("hi")
is probably the easiest methodowen
04/17/2023, 10:21 PMfrom dagster import get_dagster_logger
)Nidhin Nandhakumar
04/17/2023, 10:24 PM