ayatsuro

import hashlib
import os
from datetime import datetime

import boto3

bucket = '...'
s3 = boto3.client('s3', aws_access_key_id='...', aws_secret_access_key='...')

ayatsuro

def clear_signals(signals, window_size):
    clean_signals = [0] * window_size

    for signal_i, current_signal in enumerate(signals):
        signal_slice = clean_signals[signal_i:signal_i + window_size]
        has_past_signal = next((s for s in signal_slice if s != 0), None)
        clean_signals.append(not has_past_signal and current_signal)

    clean_signals = clean_signals[window_size:]