Skip to content

Commit

Permalink
fixing outdated processor/executor blocks
Browse files Browse the repository at this point in the history
  • Loading branch information
mat-adamec committed Feb 1, 2022
1 parent eac689e commit 46f7e51
Show file tree
Hide file tree
Showing 2 changed files with 13 additions and 12 deletions.
12 changes: 6 additions & 6 deletions docs/cc_user.rst
Original file line number Diff line number Diff line change
Expand Up @@ -220,12 +220,12 @@ Then we bundle everything up to run our job, making use of the Dask executor. To

.. code-block:: python
output = processor.run_uproot_job(fileset=fileset,
treename="Events",
processor_instance=Processor(),
executor=processor.dask_executor,
executor_args={'client': client, 'nano': True},
chunksize=250000)
executor = processor.DaskExecutor(client=client)
run = processor.Runner(executor=executor,
schema=schemas.NanoAODSchema,
)
output = run(fileset, "Events", processor_instance=Processor())
The final step is to generates a 1D histogram from the data output to the 'MET' key. fill_opts are optional arguments to fill the graph (default is a line).

Expand Down
13 changes: 7 additions & 6 deletions docs/cc_user_opendata.rst
Original file line number Diff line number Diff line change
Expand Up @@ -242,12 +242,13 @@ Then we bundle everything up to run our job, making use of the Dask executor. To

.. code-block:: python
output = processor.run_uproot_job(fileset=fileset,
treename="Events",
processor_instance=Processor(),
executor=processor.dask_executor,
executor_args={'client': client, 'nano': True},
chunksize=250000)
executor = processor.DaskExecutor(client=client)
run = processor.Runner(executor=executor,
schema=schemas.NanoAODSchema,
savemetrics=True
)
output, metrics = run(fileset, "Events", processor_instance=Processor())
The final step is to generates a 1D histogram from the data output to the 'MET' key. fill_opts are optional arguments to fill the graph (default is a line).

Expand Down

0 comments on commit 46f7e51

Please sign in to comment.