'Mark the flow for termination as soon as any of its states are called.'

@classmethod
def MarkForTermination(cls, flow_urn, mutation_pool=None, reason=None, sync=False, token=None):

    if mutation_pool:
        mutation_pool.Set(flow_urn, cls.SchemaCls.PENDING_TERMINATION.predicate, PendingFlowTermination(reason=reason), replace=False)
    else:
        data_store.DB.Set(flow_urn, cls.SchemaCls.PENDING_TERMINATION.predicate, PendingFlowTermination(reason=reason), replace=False, sync=sync, token=token)
