Skip to content

Commit

Permalink
code style.
Browse files Browse the repository at this point in the history
  • Loading branch information
mindaugasbarcauskas committed Dec 2, 2022
1 parent a4a0b55 commit 707c396
Showing 1 changed file with 2 additions and 3 deletions.
5 changes: 2 additions & 3 deletions test/integration_test.go
Expand Up @@ -422,7 +422,7 @@ func (ts *IntegrationTestSuite) TestChildWFWithParentClosePolicyTerminate() {
resp, err := ts.libClient.DescribeWorkflowExecution(context.Background(), childWorkflowID, "")
ts.NoError(err)
// Need to wait for child workflow to finish as well otherwise test becomes flaky
err = ts.waitForWorkflowFinish(resp.WorkflowExecutionInfo.Execution.GetWorkflowId(), resp.WorkflowExecutionInfo.Execution.GetRunId())
ts.waitForWorkflowFinish(resp.WorkflowExecutionInfo.Execution.GetWorkflowId(), resp.WorkflowExecutionInfo.Execution.GetRunId())
resp, err = ts.libClient.DescribeWorkflowExecution(context.Background(), childWorkflowID, "")
ts.NoError(err)
ts.True(resp.WorkflowExecutionInfo.GetCloseTime() > 0)
Expand Down Expand Up @@ -591,8 +591,7 @@ func (ts *IntegrationTestSuite) waitForWorkflowFinish(wid string, runId string)
defer cancel()
wfRun := ts.libClient.GetWorkflow(ctx, wid, runId)
var val interface{}
err := wfRun.Get(ctx, &val)
return err
return wfRun.Get(ctx, &val)
}

var _ interceptors.WorkflowInterceptorFactory = (*tracingInterceptorFactory)(nil)
Expand Down

0 comments on commit 707c396

Please sign in to comment.