

def filter_lag(source):
    '\n    Lag based filter\n    '
    for (server, worker, password) in source:
        if ((server, worker, password) not in lagged):
            (yield (server, worker, password))

dataset/ETHPy150Open c00w/bitHopper/bitHopper/LaggingLogic/__init__.py filter_lag/original