fix(s3): fix matched event name in S3 change stream (#492)

badmonster0 · web-flow · commit 05f9b6038043 · 2025-05-14T22:51:48.000-07:00
diff --git a/src/ops/sources/amazon_s3.rs b/src/ops/sources/amazon_s3.rs
@@ -256,7 +256,7 @@ impl Executor {
                         continue;
                     }
                     if record.event_name.starts_with("ObjectCreated:")
-                        || record.event_name.starts_with("ObjectDeleted:")
+                        || record.event_name.starts_with("ObjectRemoved:")
                     {
                         changes.push(SourceChange {
                             key: KeyValue::Str(s3.object.key.into()),

Original file line number	Diff line number	Diff line change
`@@ -256,7 +256,7 @@ impl Executor {`
`256`	`256`	`continue;`
`257`	`257`	`}`
`258`	`258`	`if record.event_name.starts_with("ObjectCreated:")`
`259`		`- \|\| record.event_name.starts_with("ObjectDeleted:")`
	`259`	`+ \|\| record.event_name.starts_with("ObjectRemoved:")`
`260`	`260`	`{`
`261`	`261`	`changes.push(SourceChange {`
`262`	`262`	`key: KeyValue::Str(s3.object.key.into()),`