© 2026 Hedgehog Software, LLC
export async function main(event: SQSEvent) { const records: SQSRecord[] = event.Records; Effect.forEachPar( records, flow( parseRecord, Effect.flatMap((msg) => { return Effect.ifEffect( canJobBeProcessed(msg.jobId), () => { console.log('Can be processed') return Effect.succeed(true) }, () => { console.log('Too many retry') return Effect.fail(false) } ) }) ) ) }
canJobBeProcessed(msg.jobId)
Effect<never, boolean, boolean>