def handle_event()

in gremlin/neptune-streams/lambda/neptune-streams-demo/neptune_stream_handler.py [0:0]


    def handle_event(self, op, data):
        
        type = data['type']
        if op == ADD_OPERATION:
            if type == 'vl':
                self.__increment_vertex_count()
            if type == 'e':
                self.__update_degree_centrality(data['to'])
                
        if op == REMOVE_OPERATION:
            if type == 'vl':
                self.__decrement_vertex_count()
            if type == 'e':
                self.__update_degree_centrality(data['to'])