Skip to content

Commit

Permalink
fix: add back invocation cid
Browse files Browse the repository at this point in the history
  • Loading branch information
vasco-santos committed May 30, 2024
1 parent 6306a8f commit ffe8360
Showing 1 changed file with 4 additions and 0 deletions.
4 changes: 4 additions & 0 deletions upload-api/stores/agent/stream.js
Original file line number Diff line number Diff line change
Expand Up @@ -99,6 +99,7 @@ export const assert = async (message, { stream, store }) => {
JSON.stringify({
// This is bad naming but not worth a breaking change
carCid: message.toString(),
invocationCid: invocation.cid.toString(),
task: task.toString(),
value: {
att: invocation.capabilities,
Expand All @@ -110,6 +111,9 @@ export const assert = async (message, { stream, store }) => {
type: stream.workflow.type,
})
),
// https://docs.aws.amazon.com/streams/latest/dev/key-concepts.html
// A partition key is used to group data by shard within a stream.
// It is required, and now we are starting with one shard. We need to study best partition key
PartitionKey: stream.partitionKey,
})
}
Expand Down

0 comments on commit ffe8360

Please sign in to comment.