fatal: [noc-node1]: FAILED! => {
"changed": true,
"cmd": [
"./noc",
"migrate-liftbridge"
],
"delta": "0:00:02.101108",
"end": "2021-12-23 10:57:19.311770",
"rc": 2,
"start": "2021-12-23 10:57:17.210662"
}
STDOUT:
2021-12-23 10:57:17,835 [noc.core.ioloop.util] Setting up asyncio event loop policy
2021-12-23 10:57:17,835 [noc.core.ioloop.util] Setting up default event loop
2021-12-23 10:57:17,913 [noc.core.dcs.base] Resolve near service postgres
2021-12-23 10:57:17,917 [noc.core.dcs.base] Resolved near service postgres to ['
192.168.48.72:5432']
2021-12-23 10:57:18,224 [noc.core.cache.base] Using cache backend: noc.core.cache.mongo.MongoCache
2021-12-23 10:57:18,583 [noc.core.dcs.base] Resolve near service liftbridge
2021-12-23 10:57:18,585 [noc.core.dcs.base] Resolved near service liftbridge to ['
192.168.48.72:9292']
2021-12-23 10:57:18,595 [stub] Activating stub service
2021-12-23 10:57:18,596 [stub] Starting IOLoop
Ensuring stream revokedtokens
2021-12-23 10:57:18,596 [noc.core.dcs.base] Attempting to get slot
Ensuring stream message
2021-12-23 10:57:18,598 [noc.core.dcs.base] Attempting to get slot
Ensuring stream tgsender
2021-12-23 10:57:18,600 [noc.core.dcs.base] Attempting to get slot
Ensuring stream icqsender
2021-12-23 10:57:18,601 [noc.core.dcs.base] Attempting to get slot
Ensuring stream mailsender
2021-12-23 10:57:18,603 [noc.core.dcs.base] Attempting to get slot
Ensuring stream kafkasender
2021-12-23 10:57:18,605 [noc.core.dcs.base] Attempting to get slot
Ensuring stream metrics
2021-12-23 10:57:18,606 [noc.core.dcs.base] Attempting to get slot
Ensuring stream jobs
Altering stream jobs due to partition/replication factor mismatch (1 -> 2)
Altering stream jobs
Creating temporary stream __tmp-jobs
2021-12-23 10:57:18,950 [noc.core.debug] UNHANDLED EXCEPTION (2021-12-23 10:57:18.687114)
PROCESS: ./commands/
migrate-liftbridge.pyVERSION: 20.4+master.2197.5e12834b
BRANCH: master CHANGESET: 5e12834b
ERROR FINGERPRINT: 134ffa81-f76e-5b0e-bf57-daac5b9c703c
WORKING DIRECTORY: /opt/noc
EXCEPTION: <class 'noc.core.liftbridge.error.ErrorAlreadyExists'> stream already exists