...
 
Commits (2)
......@@ -162,6 +162,7 @@ class DCMCClientHttp(DCMCClient):
raw_json = json.dumps(json_data, indent=4)
log.debug("Posting to DCMC client at %s: %s", self._remote_uri, raw_json)
await session.post(url=self._remote_uri, json=json_data)
log.info("Migration request properly posted to DCMC")
except Exception:
log.exception("Failed to submit migration request: ")
......
......@@ -195,7 +195,7 @@ class EOPlanPoller():
self._forced_timestamp_ms = forced_timestamp_ms
async def loop(self):
last_plan_seen = "none_none_none"
all_seen_plans = set()
while True:
log.debug("EOPlanPoller: iteration")
if self._forced_timestamp_ms == 0:
......@@ -208,9 +208,9 @@ class EOPlanPoller():
eo_plans = await self.eo_plan_source.get_eo_plans(self._dc_id, start, end)
for eo_plan in eo_plans:
if eo_plan.aggregate_id != last_plan_seen:
if eo_plan.aggregate_id not in all_seen_plans:
log.warning("Got a new EO plan: %s", eo_plan)
last_plan_seen = eo_plan.aggregate_id
all_seen_plans.add(eo_plan.aggregate_id)
await self._message_queue.put(eo_plan)
else:
log.info("Got EO plan %s, which was already seen, skip", eo_plan.aggregate_id)
......