Activity Scheduled But Not Starting

Community Support
,
1

Hello,

I have created a new workflow with a new set of activities where I see the workflow starting successfully and the first activity scheduled, but the activity never starts.

Here is the Workflow History:

image
image3146×692 272 KB

I have verified that the worker, workflow, and activity are all on the same task queue (entitled “routing”), that my worker process is up and running, and that there are pollers available. Both the workflow and activity struct with all exported activity methods are all registered to the worker:

	activityStruct := &activities.ActivityStruct{
		DB:          db,
		S3Client:    s3Client,
		MaxWorkers:  temporalConfig.MaxWorkers,
		SFTPClients: sftpClients,
	}

	// register all workflows and activities to primary worker & run it
	primaryWorker := worker.InitializeWorker(temporalClient, temporalConfig.TaskQueue)
	primaryWorker.RegisterActivity(activityStruct)
	primaryWorker.RegisterWorkflow(submission.BureauSubmissionWorkflow)

	if err = primaryWorker.Run(sdkWorker.InterruptCh()); err != nil {
		log.Fatalln("unable to start temporal worker", err)
	}

I’ve checked some other threads regarding this same issue but their problems seem to be intermittent/based on things like concurrency/start to close timeout/etc., but this happens every time for me and I’m simply running this one basic workflow manually.

I have another separate service communicating with the same namespace that is functioning successfully on a separate task queue, and my worker setup code is identical in this new service, so I’m not sure what the difference could be.

I’m not really sure where to go from here - is there a way to read worker process logs in depth, or something similar?

Thanks

2

If it helps, here is the workflow definition along with the activity call:

func BureauSubmissionWorkflow(
	ctx workflow.Context,
) (responses.BureauSubmissionWorkflowResponse, error) {
	// set activity options
	ao := workflow.ActivityOptions{
		StartToCloseTimeout: 1800 * time.Second,
		RetryPolicy: &temporal.RetryPolicy{
			MaximumAttempts: 1,
		},
	}
	ctx = workflow.WithActivityOptions(ctx, ao)
	var a *activities.ActivityStruct

	retrieveS3DropFilesActivityResponse := responses.RetrieveS3DropFilesActivityResponse{}
	err := workflow.ExecuteActivity(ctx, a.RetrieveS3DropFilesActivity).
		Get(ctx, &retrieveS3DropFilesActivityResponse)
	if err != nil {
		return responses.BureauSubmissionWorkflowResponse{}, err
	}
    ......................
}
3

Hello @mdross95

ActivityTaskStarted / failed is only written in event history when the activity complete (success of fail).
There are a couple of things you can try:

also, I am not sure if I am reading the code correctly, but I don’t see RetrieveS3DropFilesActivity in the ActivityStruct

Antonio