fix unit tests

Author: jbsmith7741

.circleci/config.yml

@@ -1,10 +1,14 @@
-version: 2
+version: 2.1 
 
-jobs:
-  build:
+executors:
+  go-executor:
     docker:
       - image: cimg/go:1.23
-    working_directory: ~/task-tools
+    working_directory: ~/task-tools 
+
+jobs:
+  test:
+    executor: go-executor 
     steps:
       - checkout
       - run: go install github.com/jstemmer/go-junit-report/v2@latest
@@ -23,4 +27,36 @@ jobs:
       - store_artifacts:
           path: ~/task-tools/junit
       - store_artifacts:
-          path: tests.out
+          path: tests.out
+  
+  build:
+    executor: go-executor
+    steps:
+      - checkout
+      - setup_remote_docker:
+          docker_layer_caching: false
+      - run: 
+          name: "docker login" 
+          command: echo ${DOCKERHUB_TOKEN} | docker login -u ${DOCKERHUB_USERNAME} --password-stdin
+      - run:
+          name: "Push Docker Image"
+          command: make push
+
+workflows:
+  version: 2
+  test_and_build: 
+    jobs: 
+      - test: 
+          filters: 
+            tags: 
+              only: 
+                - /.*/
+      - build: 
+          requires: 
+            - test
+          context: 
+            - DOCKER
+          filters: 
+            tags: 
+              only: 
+                - /.*/

apps/flowlord/taskmaster_test.go

@@ -15,14 +15,15 @@ import (
 	"github.com/pcelvng/task/bus/nop"
 	"github.com/robfig/cron/v3"
 
+	"github.com/pcelvng/task-tools/apps/flowlord/cache"
 	"github.com/pcelvng/task-tools/workflow"
 )
 
 const base_test_path string = "../../internal/test/"
 
 func TestTaskMaster_Process(t *testing.T) {
 	delayRegex := regexp.MustCompile(`delayed=(\d+.\d+)`)
-	cache, fatalErr := workflow.New(base_test_path+"workflow", nil)
+	workflowCache, fatalErr := workflow.New(base_test_path+"workflow", nil)
 	if fatalErr != nil {
 		t.Fatal("cache init", fatalErr)
 	}
@@ -32,7 +33,12 @@ func TestTaskMaster_Process(t *testing.T) {
 	}
 	fn := func(tsk task.Task) ([]task.Task, error) {
 		var alerts int64
-		tm := taskMaster{doneConsumer: consumer, Cache: cache, failedTopic: "failed-topic", alerts: make(chan task.Task), slack: &Notification{}}
+		// Initialize taskCache for the test
+		taskCache, err := cache.NewSQLite(time.Hour, ":memory:")
+		if err != nil {
+			return nil, err
+		}
+		tm := taskMaster{doneConsumer: consumer, Cache: workflowCache, taskCache: taskCache, failedTopic: "failed-topic", alerts: make(chan task.Task), slack: &Notification{}}
 		producer, _ := nop.NewProducer("")
 		tm.producer = producer
 		nop.FakeMsg = tsk.JSONBytes()