mirror of
https://github.com/woodpecker-ci/woodpecker.git
synced 2026-09-05 20:07:25 +00:00
6543
60df1c618d
because we now wait for all steps to trace status back before we return, the defere did not tear down services anymore ... ... we now explicit tear down services and steps after all stages have executed. Also adds tests to check for that and update the dummy backend to fullfill the interface contract of killing all "running" steps with DestroyWorkflow.
81 lines
2.3 KiB
Go
81 lines
2.3 KiB
Go
// Copyright 2023 Woodpecker Authors
|
|
//
|
|
// Licensed under the Apache License, Version 2.0 (the "License");
|
|
// you may not use this file except in compliance with the License.
|
|
// You may obtain a copy of the License at
|
|
//
|
|
// http://www.apache.org/licenses/LICENSE-2.0
|
|
//
|
|
// Unless required by applicable law or agreed to in writing, software
|
|
// distributed under the License is distributed on an "AS IS" BASIS,
|
|
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
// See the License for the specific language governing permissions and
|
|
// limitations under the License.
|
|
|
|
package runtime
|
|
|
|
import (
|
|
"context"
|
|
"sync"
|
|
|
|
"github.com/oklog/ulid/v2"
|
|
"github.com/rs/zerolog"
|
|
"github.com/rs/zerolog/log"
|
|
|
|
backend_types "go.woodpecker-ci.org/woodpecker/v3/pipeline/backend/types"
|
|
"go.woodpecker-ci.org/woodpecker/v3/pipeline/logging"
|
|
"go.woodpecker-ci.org/woodpecker/v3/pipeline/tracing"
|
|
"go.woodpecker-ci.org/woodpecker/v3/shared/utils"
|
|
)
|
|
|
|
// Runtime represents a workflow state executed by a specific backend.
|
|
// Each workflow gets its own Runtime instance.
|
|
type Runtime struct {
|
|
// err holds the first error that occurred in the workflow.
|
|
err utils.Protected[error]
|
|
|
|
spec *backend_types.Config
|
|
engine backend_types.Backend
|
|
started int64
|
|
|
|
// ctx is the context for the current workflow execution.
|
|
// All normal (non-cleanup) step operations must use this context.
|
|
// Cleanup operations should use the runnerCtx passed to Run().
|
|
ctx context.Context
|
|
|
|
tracer tracing.Tracer
|
|
tracerLock sync.Mutex
|
|
logger logging.Logger
|
|
|
|
uploadWait sync.WaitGroup
|
|
|
|
taskUUID string
|
|
description map[string]string
|
|
}
|
|
|
|
// New returns a new Runtime for the given workflow spec and options.
|
|
func New(spec *backend_types.Config, backend backend_types.Backend, opts ...Option) *Runtime {
|
|
r := new(Runtime)
|
|
r.err = utils.NewProtected[error](nil)
|
|
r.description = map[string]string{}
|
|
r.spec = spec
|
|
r.engine = backend
|
|
r.ctx = context.Background()
|
|
r.taskUUID = ulid.Make().String()
|
|
r.tracer = tracing.NoOpTracer
|
|
r.tracerLock = sync.Mutex{}
|
|
for _, opt := range opts {
|
|
opt(r)
|
|
}
|
|
return r
|
|
}
|
|
|
|
// makeLogger returns a logger enriched with all runtime description fields.
|
|
func (r *Runtime) makeLogger() zerolog.Logger {
|
|
logCtx := log.With()
|
|
for key, val := range r.description {
|
|
logCtx = logCtx.Str(key, val)
|
|
}
|
|
return logCtx.Logger()
|
|
}
|