merge to 1.3.0

This commit is contained in:
dhaval055
2023-10-12 16:03:38 +00:00
24 changed files with 2411 additions and 199 deletions
+4 -1
View File
@@ -3499,9 +3499,11 @@ func handleCloudExecutionOnprem(workflowId, startNode, executionSource, executio
}
func handleCloudJob(job shuffle.CloudSyncJob) error {
ctx := context.Background()
// May need authentication in all of these..?
log.Printf("[INFO] Handle job with type %s and action %s", job.Type, job.Action)
shuffle.IncrementCache(ctx, job.OrgId, "org_sync_actions")
if job.Type == "outlook" {
if job.Action == "execute" {
// FIXME: Get the email
@@ -6110,6 +6112,7 @@ func initHandlers() {
// Had to move away from mux, which means Method is fucked up right now.
func main() {
initHandlers()
go shuffle.InitOpsWorkflow()
hostname, err := os.Hostname()