def METHOD_NAME(self, query_pk, query_version, status_time, results, distributed_query_pk=None):
    try:
        status = max(Status[r["ztl_status"].upper()] for r in results)
    except Exception:
        status = Status.UNKNOWN
    update_key = False
    try:
        _, _, stored_status_time, _ = self.cc_statuses[query_pk]
    except KeyError:
        update_key = True
    else:
        if status_time and stored_status_time:
            update_key = status_time > stored_status_time
    if update_key:
        self.cc_statuses[query_pk] = (query_version, status, status_time, distributed_query_pk)