509
}
510
512
>
metrics.HeaderSize.With(metricsHandler).Record(int64(attr.GetHeader().Size()))
513
>
if err := handler.sizeLimitChecker.checkIfPayloadSizeExceedsLimit(
514
>
metrics.CommandTypeTag(enumspb.COMMAND_TYPE_SCHEDULE_ACTIVITY_TASK.String()),
515
>
attr.GetInput().Size(),
516
>
"ScheduleActivityTaskCommandAttributes.Input exceeds size limit.",
517
>
); err != nil {
518
return nil, nil, handler.terminateWorkflow(enumspb.WORKFLOW_TASK_FAILED_CAUSE_BAD_SCHEDULE_ACTIVITY_ATTRIBUTES, err)
519
}
521
return nil, nil, handler.failWorkflowTask(enumspb.WORKFLOW_TASK_FAILED_CAUSE_PENDING_ACTIVITIES_LIMIT_EXCEEDED, err)
522
}
523
525
>
526
>
namespace := handler.mutableState.GetNamespaceEntry().Name().String()
527
>
528
>
// TODO: versioning 3 allows eager activity dispatch for both pinned and unpinned workflows, no
529
>
// special consideration is need. Remove the versioning logic from here. [cleanup-old-wv]
530
>
oldVersioningUsed := handler.mutableState.GetMostRecentWorkerVersionStamp().GetUseVersioning() &&
531
>
// for V3 versioning it's ok to dispatch eager activities
532
>
handler.mutableState.GetEffectiveVersioningBehavior() == enumspb.VERSIONING_BEHAVIOR_UNSPECIFIED
533
>
newVersioningUsed := handler.mutableState.GetExecutionInfo().GetAssignedBuildId() != ""
534
>
versioningUsed := oldVersioningUsed || newVersioningUsed
535
>
536
>
// Enable eager activity start if dynamic config enables it and either 1. workflow doesn't use versioning,
537
>
// or 2. workflow uses versioning and activity intends to use a compatible version (since a
538
>
// worker is obviously compatible with itself and we are okay dispatching an eager task knowing that there may be a
539
>
// newer "default" compatible version).
540
>
// Note that if `UseWorkflowBuildId` is false, it implies that the activity should run on the "default" version
541
>
// for the task queue.
542
>
eagerStartActivity := attr.RequestEagerExecution && handler.config.EnableActivityEagerExecution(namespace) &&
543
>
(!versioningUsed || attr.UseWorkflowBuildId)
544
>
545
>
// if the workflow is paused, we bypass activity task generation and also prevent eager activity execution.
546
>
bypassActivityTaskGeneration := eagerStartActivity
547
>
if handler.mutableState.GetExecutionState().Status == enumspb.WORKFLOW_EXECUTION_STATUS_PAUSED {
548
bypassActivityTaskGeneration = true
549
eagerStartActivity = false
550
}
551
553
>
handler.workflowTaskCompletedID,
554
>
attr,
555
>
bypassActivityTaskGeneration,
556
>
)
557
>
if err != nil {
558
return nil, nil, handler.failWorkflowTaskOnInvalidArgument(enumspb.WORKFLOW_TASK_FAILED_CAUSE_SCHEDULE_ACTIVITY_DUPLICATE_ID, err)
559
}
560
562
return event, &handleCommandResponse{}, nil
563
}