Skip to content

Instantly share code, notes, and snippets.

@alfrcr

alfrcr/filter_out.py

Last active October 13, 2020 19:37
Show Gist options

  • Select an option

    Learn more about clone URLs
  • Save alfrcr/f9b9a982cc54bfcbf8724ddcb5f6bdb5 to your computer and use it in GitHub Desktop.

Select an option

Learn more about clone URLs
Save alfrcr/f9b9a982cc54bfcbf8724ddcb5f6bdb5 to your computer and use it in GitHub Desktop.
Download ZIP
Filter out
Raw
filter_out.py
filter_in_parallel = group(
filter_out.s(event_type, chunks, story_id, days_lookback) for chunks in chunks_fetch
).apply_async()
device_ids = []
for result in filter_in_parallel.get():
device_ids.extend(result)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment