Added start reason to pipelines. (#235)

* Added start reason to pipelines.

* Fixed failing test

* Fixed linter

* Removed redundant sentence

Author: Skarlso

frontend/package-lock.json

@@ -76,7 +76,7 @@
     "babel-eslint": "^10.0.1",
     "eslint": "^5.16.0",
     "eslint-plugin-vue": "^5.0.0",
-    "node-sass": "^4.9.0",
+    "node-sass": "^4.13.1",
     "sass-loader": "^7.1.0",
     "vue-runtime-helpers": "^1.0.1",
     "vue-template-compiler": "^2.6.10"

frontend/package.json

@@ -86,6 +86,7 @@
                 <span v-else>{{ props.row.status }}</span>
               </span>
               <span v-if="props.column.field === 'duration'">{{ calculateDuration(props.row.startdate, props.row.finishdate) }}</span>
+              <span v-if="props.column.field === 'reason'">{{ props.row.started_reason }}</span>
               <span v-if="props.column.field === 'action'">
                 <a v-on:click="stopPipelineModal(pipelineID, props.row.id)"><i class="fa fa-ban"
                                                                                style="color: whitesmoke;"></i></a>
@@ -165,6 +166,10 @@ export default {
           label: 'Duration',
           field: 'duration'
         },
+        {
+          label: 'Reason',
+          field: 'reason'
+        },
         {
           label: 'Action',
           field: 'action'

frontend/src/views/pipeline/detail.vue

@@ -139,6 +139,15 @@ const (
 
 	// ExecutablePermission is the permission used for gaia created executables.
 	ExecutablePermission = 0700
+
+	// StartReasonRemote label for pipelines which were triggered through a remote token.
+	StartReasonRemote = "remote"
+
+	// StartReasonManual label for pipelines which were triggered through the admin site.
+	StartReasonManual = "manual"
+
+	// StartReasonScheduled label for pipelines which were triggered automated process, i.e. cron job.
+	StartReasonScheduled = "scheduled"
 )
 
 // User is the user object
@@ -254,6 +263,7 @@ type PipelineRun struct {
 	ID             int               `json:"id"`
 	PipelineID     int               `json:"pipelineid"`
 	StartDate      time.Time         `json:"startdate,omitempty"`
+	StartReason    string            `json:"started_reason"`
 	FinishDate     time.Time         `json:"finishdate,omitempty"`
 	ScheduleDate   time.Time         `json:"scheduledate,omitempty"`
 	Status         PipelineRunStatus `json:"status,omitempty"`

gaia.go

@@ -196,7 +196,7 @@ func PipelineUpdate(c echo.Context) error {
 		// Iterate over all cron schedules.
 		for _, schedule := range p.PeriodicSchedules {
 			err := foundPipeline.CronInst.AddFunc(schedule, func() {
-				_, err := schedulerService.SchedulePipeline(&foundPipeline, []*gaia.Argument{})
+				_, err := schedulerService.SchedulePipeline(&foundPipeline, gaia.StartReasonScheduled, []*gaia.Argument{})
 				if err != nil {
 					gaia.Cfg.Logger.Error("cannot schedule pipeline from periodic schedule", "error", err, "pipeline", foundPipeline)
 					return
@@ -342,7 +342,7 @@ func PipelineTrigger(c echo.Context) error {
 	schedulerService, _ := services.SchedulerService()
 	var args []*gaia.Argument
 	_ = c.Bind(&args)
-	pipelineRun, err := schedulerService.SchedulePipeline(&foundPipeline, args)
+	pipelineRun, err := schedulerService.SchedulePipeline(&foundPipeline, gaia.StartReasonRemote, args)
 	if err != nil {
 		return c.String(http.StatusBadRequest, err.Error())
 	} else if pipelineRun != nil {
@@ -456,7 +456,7 @@ func PipelineStart(c echo.Context) error {
 	foundPipeline.Docker = docker
 
 	if foundPipeline.Name != "" {
-		pipelineRun, err := schedulerService.SchedulePipeline(&foundPipeline, args)
+		pipelineRun, err := schedulerService.SchedulePipeline(&foundPipeline, gaia.StartReasonManual, args)
 		if err != nil {
 			return c.String(http.StatusBadRequest, err.Error())
 		} else if pipelineRun != nil {

handlers/pipeline.go

@@ -28,7 +28,7 @@ type mockScheduleService struct {
 	err         error
 }
 
-func (ms *mockScheduleService) SchedulePipeline(p *gaia.Pipeline, args []*gaia.Argument) (*gaia.PipelineRun, error) {
+func (ms *mockScheduleService) SchedulePipeline(p *gaia.Pipeline, startReason string, args []*gaia.Argument) (*gaia.PipelineRun, error) {
 	return ms.pipelineRun, ms.err
 }
 
@@ -442,7 +442,7 @@ func TestPipelineStart(t *testing.T) {
 			t.Fatalf("expected response code %v got %v", http.StatusCreated, rec.Code)
 		}
 
-		expectedBody := `{"uniqueid":"","id":999,"pipelineid":0,"startdate":"0001-01-01T00:00:00Z","finishdate":"0001-01-01T00:00:00Z","scheduledate":"0001-01-01T00:00:00Z"}
+		expectedBody := `{"uniqueid":"","id":999,"pipelineid":0,"startdate":"0001-01-01T00:00:00Z","started_reason":"","finishdate":"0001-01-01T00:00:00Z","scheduledate":"0001-01-01T00:00:00Z"}
 `
 		body, _ := ioutil.ReadAll(rec.Body)
 		if string(body) != expectedBody {

handlers/pipeline_test.go

@@ -42,7 +42,7 @@ type mockScheduler struct {
 
 func (ms *mockScheduler) SetPipelineJobs(p *gaia.Pipeline) error { return ms.err }
 func (ms *mockScheduler) GetFreeWorkers() int32                  { return int32(0) }
-func (ms *mockScheduler) SchedulePipeline(p *gaia.Pipeline, args []*gaia.Argument) (*gaia.PipelineRun, error) {
+func (ms *mockScheduler) SchedulePipeline(p *gaia.Pipeline, startedBy string, args []*gaia.Argument) (*gaia.PipelineRun, error) {
 	return nil, ms.err
 }
 

workers/agent/agent_test.go

@@ -32,7 +32,7 @@ type mockScheduler struct {
 }
 
 func (ms *mockScheduler) Init() {}
-func (ms *mockScheduler) SchedulePipeline(p *gaia.Pipeline, args []*gaia.Argument) (*gaia.PipelineRun, error) {
+func (ms *mockScheduler) SchedulePipeline(p *gaia.Pipeline, startedBy string, args []*gaia.Argument) (*gaia.PipelineRun, error) {
 	return nil, nil
 }
 func (ms *mockScheduler) SetPipelineJobs(p *gaia.Pipeline) error            { return ms.Error }

workers/pipeline/create_pipeline_test.go

@@ -217,7 +217,7 @@ func checkActivePipelines() {
 				// Iterate over all cron schedules.
 				for _, schedule := range pipeline.PeriodicSchedules {
 					err := pipeline.CronInst.AddFunc(schedule, func() {
-						_, err := schedulerService.SchedulePipeline(pipeline, []*gaia.Argument{})
+						_, err := schedulerService.SchedulePipeline(pipeline, gaia.StartReasonScheduled, []*gaia.Argument{})
 						if err != nil {
 							gaia.Cfg.Logger.Error("cannot schedule pipeline from periodic schedule", "error", err, "pipeline", pipeline)
 							return

workers/pipeline/ticker.go

@@ -62,7 +62,7 @@ var (
 // GaiaScheduler is a job scheduler for gaia pipeline runs.
 type GaiaScheduler interface {
 	Init()
-	SchedulePipeline(p *gaia.Pipeline, args []*gaia.Argument) (*gaia.PipelineRun, error)
+	SchedulePipeline(p *gaia.Pipeline, startedBy string, args []*gaia.Argument) (*gaia.PipelineRun, error)
 	SetPipelineJobs(p *gaia.Pipeline) error
 	StopPipelineRun(p *gaia.Pipeline, runID int) error
 	GetFreeWorkers() int32
@@ -368,7 +368,7 @@ var schedulerLock = sync.RWMutex{}
 
 // SchedulePipeline schedules a pipeline. We create a new schedule object
 // and save it in our store. The scheduler will later pick this up and will continue the work.
-func (s *Scheduler) SchedulePipeline(p *gaia.Pipeline, args []*gaia.Argument) (*gaia.PipelineRun, error) {
+func (s *Scheduler) SchedulePipeline(p *gaia.Pipeline, startedReason string, args []*gaia.Argument) (*gaia.PipelineRun, error) {
 
 	// Introduce a semaphore locking here because this function can be called
 	// in parallel if multiple users happen to trigger a pipeline run at the same time.
@@ -443,6 +443,7 @@ func (s *Scheduler) SchedulePipeline(p *gaia.Pipeline, args []*gaia.Argument) (*
 		PipelineType: p.Type,
 		PipelineTags: p.Tags,
 		Docker:       p.Docker,
+		StartReason:  startedReason,
 	}
 
 	// Put run into store

workers/scheduler/scheduler.go

@@ -407,7 +407,7 @@ func TestSchedulePipeline(t *testing.T) {
 		t.Fatal(err)
 	}
 	s.Init()
-	_, err = s.SchedulePipeline(&p, prepareArgs())
+	_, err = s.SchedulePipeline(&p, gaia.StartReasonManual, prepareArgs())
 	if err != nil {
 		t.Fatal(err)
 	}
@@ -453,11 +453,11 @@ func TestSchedulePipelineParallel(t *testing.T) {
 	var wg sync.WaitGroup
 	wg.Add(2)
 	go func() {
-		run1, _ = s.SchedulePipeline(&p1, prepareArgs())
+		run1, _ = s.SchedulePipeline(&p1, gaia.StartReasonManual, prepareArgs())
 		wg.Done()
 	}()
 	go func() {
-		run2, _ = s.SchedulePipeline(&p2, prepareArgs())
+		run2, _ = s.SchedulePipeline(&p2, gaia.StartReasonManual, prepareArgs())
 		wg.Done()
 	}()
 	wg.Wait()
@@ -488,7 +488,7 @@ func TestSchedule(t *testing.T) {
 	if err != nil {
 		t.Fatal(err)
 	}
-	_, err = s.SchedulePipeline(&p, prepareArgs())
+	_, err = s.SchedulePipeline(&p, gaia.StartReasonManual, prepareArgs())
 	if err != nil {
 		t.Fatal(err)
 	}