diff --git a/platform/compliance.go b/platform/compliance.go
index 1f6ea708..619ec948 100644
--- a/platform/compliance.go
+++ b/platform/compliance.go
@@ -15,6 +15,7 @@ import (
 	"github.com/Gleipnir-Technology/nidus-sync/platform/types"
 	"github.com/aarondl/opt/omit"
 	"github.com/aarondl/opt/omitnull"
+	"github.com/rs/zerolog/log"
 )
 
 func ComplianceRequestMailerCreate(ctx context.Context, user User, site_id int32) (int32, error) {
diff --git a/platform/start.go b/platform/start.go
index 7b71a7e3..d524d7f5 100644
--- a/platform/start.go
+++ b/platform/start.go
@@ -93,6 +93,8 @@ func addWaitingJobs(ctx context.Context) error {
 				continue
 			}
 			defer txn.Rollback(ctx)
+			app_name := fmt.Sprintf("restarted job %d", job.ID)
+			txn.Exec(fmt.Sprintf("SET application_name = '%s'", app_name))
 			err = handleJob(ctx, txn, job)
 			if err != nil {
 				sublog.Error().Err(err).Msg("failed handle job")