HA Scheduler, through persisting fwk id, seems not to work properly. about pymesos HOT 4 CLOSED

@LuisMoralesAlonso can I know how do you do the HA? And framework_id should be a dict instead of a string.

from pymesos.

When I instantiate the MesosSchedulerDriver I check if the id already persisted in redis, if it's the case I include it in the framework dictionary:

if connection.hexists(os.getenv('MARATHON_APP_ID'),'fwk_id'):
    logging.info("framework id already registered in redis")
    framework.id = connection.hget(os.getenv('MARATHON_APP_ID'),'fwk_id')

from pymesos.

@LuisMoralesAlonso framework.id should be something like {"value":"12220-3440-12532-2345"} instead of "12220-3440-12532-2345"

From the snippet above, connection.hget(os.getenv('MARATHON_APP_ID'),'fwk_id') always get a string? so maybe you need to do something like framework.id = dict(value=connection.hget(os.getenv('MARATHON_APP_ID'),'fwk_id')) ?

from pymesos.

It works!!!! Thnks!!!

from pymesos.