Dimitris Stafylarakis
06/29/2022, 10:12 AMIsADirectoryError: [Errno 21] Is a directory
. This is raised by the input manager, presumably because of the logic in _get_path
def _get_path(self, context: Union[InputContext, OutputContext]) -> str:
"""Automatically construct filepath."""
if context.has_asset_key:
path = context.get_asset_identifier()
else:
path = context.get_identifier()
return os.path.join(self.base_dir, *path)
Input has asset key and partition_key, but no asset partitions.
I’m using daily partitions, set in AssetsDefinition.from_graph(.., partitions_def=daily_partitions)
Is there a workaround for this? TIAsandy
06/29/2022, 6:19 PMDimitris Stafylarakis
06/29/2022, 9:53 PMowen
06/29/2022, 11:50 PMDimitris Stafylarakis
06/30/2022, 7:19 AM