diff --git a/ops-catalog/schema-inference.flow.yaml b/ops-catalog/schema-inference.flow.yaml index 54a3f7cdfa..b52241def9 100644 --- a/ops-catalog/schema-inference.flow.yaml +++ b/ops-catalog/schema-inference.flow.yaml @@ -28,6 +28,8 @@ collections: $fields->>'collection_name' as collection_name, $fields->'schema' as schema where $message = 'inferred schema updated'; + shards: + minTxnDuration: 10s # A direct-copy of L1, but enables us to add more L1s # as we create more data planes. diff --git a/ops-catalog/task-failures.flow.yaml b/ops-catalog/task-failures.flow.yaml index 0aa8dc066c..b0b0786086 100644 --- a/ops-catalog/task-failures.flow.yaml +++ b/ops-catalog/task-failures.flow.yaml @@ -62,6 +62,8 @@ collections: source: ops.us-central1.v1/logs readDelay: 48h lambda: DELETE FROM failures WHERE shard = $name AND ts=$ts; DELETE FROM failure_notifications WHERE shard = $name AND ts=$ts; + shards: + minTxnDuration: 10s projections: ts: /ts task_name: /task_name