Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Start move to dask histEFT #422

Open
wants to merge 16 commits into
base: master
Choose a base branch
from
Open

Start move to dask histEFT #422

Changes from 1 commit
Commits
Show all changes
16 commits
Select commit Hold shift + click to select a range
fb7bb98
move run_analysis.py to new histEFT, taskvine
btovar Jul 9, 2024
0ec938a
move analysis_processor to dask
btovar Jul 9, 2024
d251a3e
Adding dask test, restoring old futures test for CI
bryates Jul 9, 2024
6a373f3
Remove blank lines
bryates Jul 9, 2024
93a4bfb
Futures was removed
bryates Jul 9, 2024
f17064b
Adding dask stuff to environment yml
bryates Jul 9, 2024
0a2801e
Unpin coffea, use python 3.10
bryates Jul 9, 2024
d8dba61
Default redirector '' -> '.'
bryates Jul 9, 2024
a206030
Use `dask_hists` branch of TopCoffea
bryates Jul 9, 2024
fc55fca
uncomment actual computation
btovar Jul 9, 2024
a87b457
Allow coffea warnings for now
bryates Jul 9, 2024
275d979
Various `da` and `dak` fixes
bryates Jul 9, 2024
40f3657
Disable random for now, other minor fixes
bryates Jul 9, 2024
5ed215f
Fix lint
bryates Jul 9, 2024
680f239
Another lint change
bryates Jul 9, 2024
ea2e8c2
Remove print
bryates Jul 9, 2024
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
uncomment actual computation
  • Loading branch information
@btovar
btovar committed Jul 9, 2024
commit fc55fcab39fc021dc275e707b689987d3bca9023
4 changes: 2 additions & 2 deletions analysis/topeft_run2/run_analysis.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -330,8 +330,8 @@ def LoadJsonToSampleName(jsonFile, prefix):
)

to_compute = {}
# for name, events_of_name in events.items():
# to_compute[name] = processor_instance.process(events_of_name)
for name, events_of_name in events.items():
to_compute[name] = processor_instance.process(events_of_name)

(output, ) = dask.compute(to_compute, **scheduler_opts)

Expand Down
Loading