Customizable throughputStress Workflow IDs (#134)

<!--- Note to EXTERNAL Contributors -->
<!-- Thanks for opening a PR! 
If it is a significant code change, please **make sure there is an open
issue** for this.
We work best with you when we have accepted the idea first before you
code. -->

<!--- For ALL Contributors 👇 -->

## What was changed
<!-- Describe what has changed in this PR -->

Allow to customize Workflow ID in throughputStress scenario.

## Why?
<!-- Tell your future self why have you made these changes -->

For our test pipeline, I need to start multiple Omes runs (since I don't
want to abort the entire pipeline run if one fails).

But changing the Omes RunID or Scenario is not possible, as that is used
to compute the task queue (Workers are deployed separately and rely on
the task queue identifier).

Thus, to avoid Workflow ID conflicts, generating unique Workflow IDs is
needed.

## Checklist
<!--- add/delete as needed --->

1. Closes <!-- add issue number here -->

2. How was this tested:
<!--- Please describe how you tested your changes/how we can test them
-->

3. Any docs updates needed?
<!--- update README if applicable
      or point out where to update docs.temporal.io -->

Author: stephanos

scenarios/throughput_stress.go

@@ -1,6 +1,7 @@
 package scenarios
 
 import (
+	"cmp"
 	"context"
 	"errors"
 	"fmt"
@@ -24,9 +25,13 @@ const (
 	SkipSleepFlag     = "skip-sleep"
 	CANEventFlag      = "continue-as-new-after-event-count"
 	NexusEndpointFlag = "nexus-endpoint"
+	WorkflowIDPrefix  = "workflow-id-prefix"
 )
 
-const ThroughputStressScenarioIdSearchAttribute = "ThroughputStressScenarioId"
+const (
+	ThroughputStressScenarioIdSearchAttribute = "ThroughputStressScenarioId"
+	defaultWorkflowIDPrefix                   = "throughputStress"
+)
 
 type tpsExecutor struct {
 	workflowCount atomic.Uint64
@@ -80,12 +85,13 @@ func (t *tpsExecutor) Run(ctx context.Context, info loadgen.ScenarioInfo) error
 			internalIterations := run.ScenarioInfo.ScenarioOptionInt(IterFlag, 5)
 			internalIterTimeout := run.ScenarioInfo.ScenarioOptionDuration(IterTimeout, time.Minute)
 			continueAsNewCount := run.ScenarioInfo.ScenarioOptionInt(CANEventFlag, 120)
+			workflowIDPrefix := cmp.Or(run.ScenarioInfo.ScenarioOptions[WorkflowIDPrefix], defaultWorkflowIDPrefix)
 			// Disabled by default.
 			nexusEndpoint := run.ScenarioInfo.ScenarioOptions[NexusEndpointFlag]
 			skipSleep := run.ScenarioInfo.ScenarioOptionBool(SkipSleepFlag, false)
 			timeout := time.Duration(internalIterations) * internalIterTimeout
 
-			wfID := fmt.Sprintf("throughputStress-%s-%d", run.RunID, run.Iteration)
+			wfID := fmt.Sprintf("%s-%s-%d", workflowIDPrefix, run.RunID, run.Iteration)
 			var result throughputstress.WorkflowOutput
 			err := run.ExecuteAnyWorkflow(ctx,
 				client.StartWorkflowOptions{
@@ -129,7 +135,6 @@ func (t *tpsExecutor) Run(ctx context.Context, info loadgen.ScenarioInfo) error
 		int(totalWorkflowCount),
 		3*time.Minute,
 	)
-
 }
 
 func init() {