diff --git a/unstructured/ingest/v2/processes/connectors/fsspec/fsspec.py b/unstructured/ingest/v2/processes/connectors/fsspec/fsspec.py
index cc277db5c1..3a1a76ca9b 100644
--- a/unstructured/ingest/v2/processes/connectors/fsspec/fsspec.py
+++ b/unstructured/ingest/v2/processes/connectors/fsspec/fsspec.py
@@ -181,7 +181,7 @@ def get_metadata(self, path: str) -> DataSourceMetadata:
 
         version = self.fs.checksum(path)
         metadata: dict[str, str] = {}
-        with contextlib.suppress(NotImplementedError):
+        with contextlib.suppress(AttributeError):
             metadata = self.fs.metadata(path)
         record_locator = {
             "protocol": self.index_config.protocol,
diff --git a/unstructured/ingest/v2/processes/connectors/fsspec/s3.py b/unstructured/ingest/v2/processes/connectors/fsspec/s3.py
index 2dc24b9d0f..7f48bdc811 100644
--- a/unstructured/ingest/v2/processes/connectors/fsspec/s3.py
+++ b/unstructured/ingest/v2/processes/connectors/fsspec/s3.py
@@ -81,8 +81,7 @@ def get_metadata(self, path: str) -> DataSourceMetadata:
         if etag := info.get("ETag"):
             version = str(etag).rstrip('"').lstrip('"')
         metadata: dict[str, str] = {}
-        metadata: dict[str, str] = {}
-        with contextlib.suppress(NotImplementedError):
+        with contextlib.suppress(AttributeError):
             metadata = self.fs.metadata(path)
         record_locator = {
             "protocol": self.index_config.protocol,