Close pgMetadata connection for S3

PeerDB-io · Nov 19, 2023 · 8b44029 · 8b44029
1 parent 085425a
commit 8b44029
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/flow/connectors/s3/s3.go b/flow/connectors/s3/s3.go
@@ -94,8 +94,8 @@ func (c *S3Connector) InitializeTableSchema(req map[string]*protos.TableSchema)
 }
 
 func (c *S3Connector) Close() error {
-	log.Debugf("Closing s3 connector is a noop")
-	return nil
+	log.Debugf("Closing metadata store connection")
+	return c.pgMetadata.Close()
 }
 
 func ValidCheck(s3Client *s3.S3, bucketURL string, metadataDB *metadataStore.PostgresMetadataStore) error {