Skip to content

Conversation

@GintasS
Copy link

@GintasS GintasS commented Apr 9, 2024

This is a PR to integrate dask functionality into ntuple-analysis.

  • Using NanoAODSchema
  • Using dask to lazily read TTrees.
  • Using dask histograms.

Performance sheet:
image

@GintasS GintasS force-pushed the fastpuppi_v1_dask_integration branch from be85d71 to f272de1 Compare April 9, 2024 13:22
@GintasS GintasS changed the base branch from fastpuppi_v1 to fastpuppi_v1_dask April 9, 2024 15:14
Copy link
Owner

@cerminar cerminar left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Is this the latest greates version?

# ROOT.fill_2Dhist(hist=hist, arrayX=flar_x, arrayY=flar_y, weights=weights)
hist.fill(flar_x, flar_y, weights)

hist.fill(flar_x, flar_y, weights)
Copy link
Owner

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Missing new-line at the end of file?

Copy link
Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Not sure what do you mean?

aliases=name_map,
entry_start=self.file_entry,
entry_stop=self.file_entry+entry_block)
dask_akarray = NanoEventsFactory.from_root(
Copy link
Owner

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

is this still up to date? did you try avoiding the loopo over the files opening all of them at once moving the NanoEventsFactory to the analyzer module?

Copy link
Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Now it is up-to-date.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants