async def METHOD_NAME(
        socket_file: string,
        partition_id: int,
        continuous: bool,
        handler: InterruptHandler
) -> None:
    partition = f'partitionid-{partition_id}'
    logging.info('starting session for %s', partition)
    with SessionClient(socket_file, partition) as client:
        if continuous:
            await run_continuously(client, handler)
        else:
            await run_once(client)