Source code for

import sys
import asyncio
import argparse

import synapse.telepath as s_telepath

import synapse.lib.output as s_output

descr = '''
Promote a mirror to the leader.

Example (being run from a Cortex mirror docker container):
    python -m

[docs]async def main(argv, outp=s_output.stdout): pars = argparse.ArgumentParser(prog='provision', description=descr) pars.add_argument('--svcurl', default='cell:///vertex/storage', help='The telepath URL of the Synapse service.') pars.add_argument('--failure', default=False, action='store_true', help='Promotion is due to leader being offline. Graceful handoff is not possible.') # TODO pars.add_argument('--timeout', type=float, default=30.0, help='The maximum timeout to wait for the mirror to catch up.') opts = pars.parse_args(argv) async with s_telepath.withTeleEnv(): async with await s_telepath.openurl(opts.svcurl) as cell: graceful = not opts.failure outp.printf(f'Promoting to leader: {opts.svcurl}') await cell.promote(graceful=graceful)
if __name__ == '__main__': # pragma: no cover sys.exit([1:])))