Method Create

sdks/go/features/schedules.go:56–102

Create creates a new scheduled workflow run.

(ctx context.Context, workflowName string, trigger CreateScheduledRunTrigger)

// Create creates a new scheduled workflow run.
func (s *SchedulesClient) Create(ctx context.Context, workflowName string, trigger CreateScheduledRunTrigger) (*rest.ScheduledWorkflows, error) {
	tracer := otel.Tracer("github.com/hatchet-dev/hatchet/sdks/go")
	ctx, span := tracer.Start(ctx, hatchetotel.SpanScheduleWorkflow,
		trace.WithSpanKind(trace.SpanKindProducer),
		trace.WithAttributes(
			attribute.String(hatchetotel.AttrInstrumentor, hatchetotel.AttrInstrumentorValue),
			attribute.String(hatchetotel.AttrWorkflowName, workflowName),
			attribute.String(hatchetotel.AttrTriggerAt, trigger.TriggerAt.Format(time.RFC3339)),
		),
	)
	defer span.End()

	workflowName = client.ApplyNamespace(workflowName, s.namespace)

	var priority *int32

	if trigger.Priority != nil {
		priorityInt := int32(*trigger.Priority)
		priority = &priorityInt
	}

	request := rest.ScheduleWorkflowRunRequest{
		Input:              trigger.Input,
		AdditionalMetadata: trigger.AdditionalMetadata,
		TriggerAt:          trigger.TriggerAt,
		Priority:           priority,
	}

	resp, err := s.api.ScheduledWorkflowRunCreateWithResponse(
		ctx,
		s.tenantId,
		workflowName,
		request,
	)
	if err != nil {
		span.SetStatus(otelcodes.Error, err.Error())
		return nil, errors.Wrap(err, "failed to create scheduled workflow run")
	}

	if err := validateJSON200Response(resp.StatusCode(), resp.Body, resp.JSON200); err != nil {
		span.SetStatus(otelcodes.Error, err.Error())
		return nil, err
	}

	span.SetStatus(otelcodes.Ok, "")
	return resp.JSON200, nil
}

// Delete removes a scheduled workflow run.
func (s *SchedulesClient) Delete(ctx context.Context, scheduledRunId string) error {