From cc63218ea4da838deefb56226fb97629e52e20ca Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Jes=C3=BAs=20Garc=C3=ADa=20Crespo?= Date: Mon, 6 Apr 2020 09:08:08 -0700 Subject: [PATCH] nha: increase hari timeout --- internal/nha/activities/hari.go | 2 +- internal/workflow/receipts.go | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/internal/nha/activities/hari.go b/internal/nha/activities/hari.go index 78e9644c..de4920d9 100644 --- a/internal/nha/activities/hari.go +++ b/internal/nha/activities/hari.go @@ -22,7 +22,7 @@ import ( var hariClient = &http.Client{ // Unusual high value but needed since the server seems to be doing the indexing work synchronously. - Timeout: 10 * time.Minute, + Timeout: 20 * time.Minute, Transport: &http.Transport{ DialContext: (&net.Dialer{ Timeout: 5 * time.Second, diff --git a/internal/workflow/receipts.go b/internal/workflow/receipts.go index adca7d0b..ed3b7e43 100644 --- a/internal/workflow/receipts.go +++ b/internal/workflow/receipts.go @@ -24,7 +24,7 @@ func (w *ProcessingWorkflow) sendReceipts(ctx workflow.Context, params *sendRece if disabled, _ := manager.HookAttrBool(w.manager.Hooks, "hari", "disabled"); !disabled { opts := workflow.ActivityOptions{ ScheduleToStartTimeout: forever, - StartToCloseTimeout: time.Minute * 10, + StartToCloseTimeout: time.Minute * 20, } err := executeActivityWithAsyncErrorHandling(ctx, w.manager.Collection, params.CollectionID, opts, nha_activities.UpdateHARIActivityName, &nha_activities.UpdateHARIActivityParams{ SIPID: params.SIPID,