Clean up.

artie-labs · Nov 21, 2024 · 7493bab · 7493bab
1 parent bcedca7
commit 7493bab
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/clients/s3/s3.go b/clients/s3/s3.go
@@ -49,8 +49,7 @@ func (s *Store) IdentifierFor(topicConfig kafkalib.TopicConfig, table string) sq
 func (s *Store) ObjectPrefix(tableData *optimization.TableData) string {
 	tableID := s.IdentifierFor(tableData.TopicConfig(), tableData.Name())
 	fqTableName := tableID.FullyQualifiedName()
-	yyyyMMDDFormat := tableData.LatestCDCTs.Format(ext.PostgresDateFormat)
-
+	yyyyMMDDFormat := fmt.Sprintf("date=%s", tableData.LatestCDCTs.Format(ext.PostgresDateFormat))
 	if len(s.config.S3.FolderName) > 0 {
 		return strings.Join([]string{s.config.S3.FolderName, fqTableName, yyyyMMDDFormat}, "/")
 	}