Merge pull request #400 from flaviocirillo/development

Improved robustness for stale information into Designer

master/taskMgr.go

@@ -314,9 +314,11 @@ func (flow *FogFlow) expandExecutionPlan(entityID string, inputSubscription *Inp
 					if newOptimalWorkerID != task.WorkerID {
 						INFO.Println("[Task migration]:", task.TaskID, " migrated from ", task.WorkerID, " to ", newOptimalWorkerID)
 
-						removeTaskAction := flow.removeExistingTask(task)
-						deploymentActions = append(deploymentActions, removeTaskAction)
-
+						if (task.WorkerID != ""){
+							removeTaskAction := flow.removeExistingTask(task)
+							deploymentActions = append(deploymentActions, removeTaskAction)
+						}
+
 						task.WorkerID = newOptimalWorkerID
 
 						addTaskAction := flow.addNewTask(task)

release/latest/cloud/config-template.json

@@ -0,0 +1,53 @@
+{
+    "my_hostip": "172.17.0.1",
+    "physical_location":{
+        "longitude": 139,
+        "latitude": 35
+    },
+    "site_id": "001",
+    "logging":{
+        "info":"stdout",
+        "error":"stdout",
+        "protocol": "stdout",
+        "debug": "stdout"
+    },
+    "discovery": {
+        "http_port": 8090,
+        "storeOnDisk": true,
+        "delayStoreOnFile" : 3
+    },
+    "broker": {
+        "http_port": 8070,
+        "heartbeat_interval": 30
+    },     
+    "master": {
+        "ngsi_agent_port": 1060,
+        "rest_api_port": 8010,
+        "infinite_reconnection_tries": true    
+    },
+    "worker": {
+        "container_autoremove": false,
+        "start_actual_task": true,
+        "capacity": 8,
+        "heartbeat_interval": 30,
+        "detection_duration": 10,
+        "infinite_reconnection_tries": true
+    },
+    "designer": {
+        "webSrvPort": 8080,
+        "agentPort": 1030,
+        "ldAgentPort":1090,
+	"doNotInitApplications":true
+    },    
+    "rabbitmq": {
+        "port": 5672,
+        "username": "admin",
+        "password":"mypass"
+    },
+    "https": {
+        "enabled" : false
+    },
+    "persistent_storage": {
+        "port": 9082
+    }     
+}