'created': self.spec_created[spec.service_name()].strftime(DATEFMT),
}, sort_keys=True),
)
+ self.mgr.events.for_service(spec, OrchestratorEvent.INFO, 'service was created')
def rm(self, service_name):
# type: (str) -> bool
container_image_id=dd.container_image_id,
container_image_name=dd.container_image_name,
spec=spec,
+ events=self.events.get_for_service(spec.service_name()),
)
if n in self.spec_store.specs:
if dd.daemon_type == 'osd':
spec=spec,
size=spec.placement.get_host_selection_size(self.inventory.all_specs()),
running=0,
+ events=self.events.get_for_service(spec.service_name()),
)
if service_type == 'nfs':
spec = cast(NFSServiceSpec, spec)
'service_id': 'r.z',
'service_name': 'rgw.r.z',
'service_type': 'rgw',
- 'status': {'running': 0, 'size': 1}
+ 'status': {'running': 0, 'size': 1},
}
]
+ for o in out:
+ if 'events' in o:
+ del o['events'] # delete it, as it contains a timestamp
assert out == expected
assert [ServiceDescription.from_json(o).to_json() for o in expected] == expected