Ben Gatewood
08/23/2022, 4:51 AM@op(
ins={"unpartitioned": In(asset_key=AssetKey(["unpartitioned_asset"]), input_manager_key="io_manager")},
required_resource_keys={"io_manager", "gcs"}
)
def unconnected_asset(context, unpartitioned):
print(unpartitioned)
But this does not:
@op(
ins={"partitioned": In(asset_key=AssetKey(["partitioned_asset"]),
asset_partitions={"partition_name_string"},
input_manager_key="io_manager")},
required_resource_keys={"io_manager", "gcs"}
)
def unconnected_asset2(context, partitioned):
print(partitioned)
chris
08/23/2022, 11:52 PMBen Gatewood
08/23/2022, 11:53 PM