Merge branch 'develop' v0.8.13

CHANGELOG.md

@@ -7,6 +7,11 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 
 ## [Unreleased]
 
+## [0.8.13] - 2024-05-22
+### Fixed
+- #138: Very delayed transcripts when using CallTranscriberLambda
+- #140: Very delayed transcripts when using Connect-KVS audio ingestion
+
 ## [0.8.12] - 2024-05-20
 ### Fixed
 - Expanded redaction support to include all languages (and dialects) on the Amazon Transcribe supported languages page.
@@ -373,6 +378,7 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 - Initial release
 
 [Unreleased]: https://github.com/aws-samples/amazon-transcribe-live-meeting-assistant/compare/main...develop
+[0.8.13]: https://github.com/aws-samples/amazon-transcribe-live-call-analytics/compare/v0.8.12...v0.8.13
 [0.8.12]: https://github.com/aws-samples/amazon-transcribe-live-call-analytics/compare/v0.8.11...v0.8.12
 [0.8.11]: https://github.com/aws-samples/amazon-transcribe-live-call-analytics/compare/v0.8.10...v0.8.11
 [0.8.10]: https://github.com/aws-samples/amazon-transcribe-live-call-analytics/compare/v0.8.9...v0.8.10

VERSION

@@ -1 +1 @@
-0.8.12
+0.8.13

lca-ai-stack/VERSION

@@ -1 +1 @@
-0.8.12
+0.8.13

lca-ai-stack/deployment/lca-ai-stack.yaml

@@ -285,7 +285,7 @@ Parameters:
 
  BootstrapVersion:
  Type: String
- Default: 0.8.12
+ Default: 0.8.13
  Description: >
  Artifacts version (semver). Used to point to a specific release in the S3
  bootstrap bucket

lca-ai-stack/samconfig.toml

@@ -8,20 +8,20 @@ use_container = true
 # shared account
 [shared.global.parameters]
 s3_bucket = "lca-artifacts-253873381732-us-east-1"
-s3_prefix = "artifacts/lca/0.8.12"
+s3_prefix = "artifacts/lca/0.8.13"
 
 [shared.deploy.parameters]
 stack_name = "LiveCallAnalytics"
 s3_bucket = "lca-artifacts-253873381732-us-east-1"
-s3_prefix = "artifacts/lca/0.8.12"
+s3_prefix = "artifacts/lca/0.8.13"
 region = "us-east-1"
 fail_on_empty_changeset = false
 confirm_changeset = true
 capabilities = "CAPABILITY_IAM CAPABILITY_AUTO_EXPAND"
 parameter_overrides = [
  "BootstrapBucketBaseName=lca-artifacts-253873381732",
  "BootstrapS3Prefix=artifacts/lca",
- "BootstrapVersion=0.8.12",
+ "BootstrapVersion=0.8.13",
  "S3BucketName=shared-ai-for-chime-vc-audio",
  "IsContentRedactionEnabled=true",
  "IsSentimentAnalysisEnabled=true",
@@ -32,4 +32,4 @@ parameter_overrides = [
 
 [shared.package.parameters]
 s3_bucket = "lca-artifacts-253873381732-us-east-1"
-s3_prefix = "artifacts/lca/0.8.12"
+s3_prefix = "artifacts/lca/0.8.13"

lca-ai-stack/source/ui/package.json

@@ -1,6 +1,6 @@
 {
  "name": "lca-ui",
- "version": "0.8.12",
+ "version": "0.8.13",
  "private": true,
  "dependencies": {
  "@aws-amplify/ui-components": "^1.9.6",

lca-chimevc-stack/cloudformation-templates/chime-vc-call-transcriber.yaml

@@ -196,7 +196,7 @@ Resources:
  Environment:
  Variables:
  TRANSCRIBE_API_MODE: !Ref TranscribeApiMode
- BUFFER_SIZE: '128'
+ BUFFER_SIZE: '3200'
  LAMBDA_INVOKE_TIMEOUT: '720000'
  KINESIS_STREAM_NAME: !Ref KinesisDataStreamName
  TRANSCRIBER_CALL_EVENT_TABLE_NAME: !Ref TranscriberCallEventTable

lca-chimevc-stack/lambda_functions/call_transcriber/index.js

@@ -588,7 +588,7 @@ const readKVS = async (streamName, streamArn, lastFragment, streamPipe, callData
 
  if (callData.originalCallId !== fragmentCallId) {
  console.log(`Error: ${streamName}'s MKV data has a Chime CallId of ${fragmentCallId}, expecting ${callData.originalCallId}. (CallId: ${callData.callId})`);
- 
+
  (async () => {
  // write is call ended. Since these are async, calling them from within an anonymous promise
  console.log(`Mismatched CallId indicates that KVS stream has been recycled. We must end this call. (CallId: ${callData.callId})`);
@@ -892,10 +892,10 @@ const go = async function go(callData) {
  const callEnded = await checkIfCallEnded(callId);
  if (callEnded) {
  console.log(`clearing CHECK_CALL_STATUS interval. (CallId: ${callId})`);
- clearInterval(callStatusCheckTimer); 
+ clearInterval(callStatusCheckTimer);
  callStatusCheckTimer = undefined;
  }
- }, CHECK_CALL_STATUS_INTERVAL_MILLISECONDS); 
+ }, CHECK_CALL_STATUS_INTERVAL_MILLISECONDS);
 
  const transcribePromise = readTranscripts(tsStream, callId, sessionId);
 
@@ -957,7 +957,7 @@ const handler = async function handler(event, context) {
  // make sure we've not inherited a running callStatusCheckTimer from a previously aborted lambda invocation
  if (callStatusCheckTimer) {
  console.log('Clearing previous callStatusCheckTimer');
- clearInterval(callStatusCheckTimer); 
+ clearInterval(callStatusCheckTimer);
  callStatusCheckTimer = undefined;
  }
 
@@ -1077,7 +1077,7 @@ const handler = async function handler(event, context) {
  }
 
  console.log(`CallData: `, JSON.stringify(callData));
- let result; 
+ let result;
  try {
  result = await go(callData);
  } catch (error) {

lca-connect-kvs-stack/template.yaml

@@ -363,7 +363,7 @@ Resources:
  Variables:
  CONNECT_INSTANCE_ARN: !Ref ConnectInstanceArn
  TRANSCRIBE_API_MODE: !Ref TranscribeApiMode
- BUFFER_SIZE: '128'
+ BUFFER_SIZE: '3200'
  LAMBDA_INVOKE_TIMEOUT: '720000'
  KINESIS_STREAM_NAME: !Ref KinesisDataStreamName
  TRANSCRIBER_CALL_EVENT_TABLE_NAME: !Ref TranscriberCallEventTable

lca-main.yaml

@@ -15,7 +15,7 @@
 AWSTemplateFormatVersion: '2010-09-09'
 Transform: AWS::Serverless-2016-10-31
 
-Description: Amazon Transcribe Live Call Analytics with Agent Assist - LCA (v0.8.12) (SO9072)
+Description: Amazon Transcribe Live Call Analytics with Agent Assist - LCA (v0.8.13) (SO9072)
 
 Parameters:
  CallAudioSource: