Functional Analysis Description Language Base Package
Project description
func_adl
Construct hierarchical data queries using SQL-like concepts in python.
func_adl Uses an SQL like language, and extracts data and computed values from a ROOT file or an ATLAS xAOD file
and returns them in a columnar format. It is currently used as a central part of two of the ServiceX transformers.
This is the base package that has the backend-agnostic code to query hierarchical data. In all likelihood you will want to install one of the following packages:
- func_adl_xAOD: for running on an ATLAS & CMS experiment xAOD file hosted in ServiceX
- func_adl_uproot: for running on flat root files
- func_adl.xAOD.backend: for running on a local file using docker
See the documentation for more information on what expressions and capabilities are possible in each of these backends.
Extensibility
There are two several extensibility points:
EventDatasetshould be sub-classed to provide an executor.EventDatasetcan use Python's type system to allow for editors and other intelligent typing systems to type check expressions. The more type data present, the more the system can help.- It is possible to insert a call back at a function or method call site that will allow for modification of the
ObjectStreamor the call site'sast.
EventDataSet
An example EventDataSet:
class events(EventDataset):
async def execute_result_async(self, a: ast.AST, title: Optional[str] = None):
await asyncio.sleep(0.01)
return a
and some func_adl code that uses it:
r = (events()
.SelectMany(lambda e: e.Jets('jets'))
.Select(lambda j: j.eta())
.value())
- When the
.value()method is invoked, theexecute_result_asyncwith a completeastrepresenting the query is called. This is the point that one would send it to the backend to actually be processed. - Normally, the constructor of
eventswould take in the name of the dataset to be processed, which could then be used inexecute_result_async.
Typing EventDataset
A minor change to the declaration above, and no change to the query:
class dd_jet:
def pt(self) -> float:
...
def eta(self) -> float:
...
class dd_event:
def Jets(self, bank: str) -> Iterable[dd_jet]:
...
def EventNumber(self, bank='default') -> int
...
class events(EventDataset[dd_event]):
async def execute_result_async(self, a: ast.AST, title: Optional[str] = None):
await asyncio.sleep(0.01)
return a
This is not required, but when this is done:
- Editors that use types to give one a list of options/guesses will now light up as long as they have reasonable type-checking built in.
- If a required argument is missed, an error will be generated
- If a default argument is missed, it will be automatically filled in.
It should be noted that the type and expression follower is not very sophisticated! While it can follow method calls, it won't follow much else!
Type-based callbacks
By adding a function and a reference in the type system, arbitrary code can be executed during the traversing of the func_adl. Keeping the query the same and the events definition the same, we can add the info directly to the python type declarations:
def add_md_for_type(s: ObjectStream[T], a: ast.Call) -> Tuple[ObjectStream[T], ast.AST]:
return s.MetaData({'hi': 'there'}), a
class dd_event:
_func_adl_type_info = add_md_for_type
def Jets(self, bank: str) -> Iterable[dd_jet]:
...
- When the
.Jets()method is processed, theadd_md_for_typeis called with the current object stream and the ast. add_md_for_typehere adds metadata and returns the updated stream and ast.- Nothing prevents the function from parsing the AST, removing or adding arguments, adding more complex metadata, or doing any of this depending on the arguments in the call site.
Development
After a new release has been built and passes the tests you can release it by creating a new release on github. An action that runs when a release is "created" will send it to pypi.
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
Built Distribution
File details
Details for the file func_adl-2.4b4.tar.gz.
File metadata
- Download URL: func_adl-2.4b4.tar.gz
- Upload date:
- Size: 16.0 kB
- Tags: Source
- Uploaded using Trusted Publishing? No
- Uploaded via: twine/3.4.2 importlib_metadata/4.8.1 pkginfo/1.7.1 requests/2.26.0 requests-toolbelt/0.9.1 tqdm/4.62.3 CPython/3.8.12
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 | cd64a541474d4970d62cf1f4457608dec0e4c0136e7ad6f994dbcaeaaffea2f2 |
|
| MD5 | 643ca96a64437bb49512107aae7c7813 |
|
| BLAKE2b-256 | 0f3e4d8ff9240e623c6053d84455e2364a686743b5ece7fc18906b388d78e59a |
File details
Details for the file func_adl-2.4b4-py3-none-any.whl.
File metadata
- Download URL: func_adl-2.4b4-py3-none-any.whl
- Upload date:
- Size: 16.0 kB
- Tags: Python 3
- Uploaded using Trusted Publishing? No
- Uploaded via: twine/3.4.2 importlib_metadata/4.8.1 pkginfo/1.7.1 requests/2.26.0 requests-toolbelt/0.9.1 tqdm/4.62.3 CPython/3.8.12
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 | b9d01e84ad375c8fb73c93d2e8a794a9fecd38c37f27f421dd12a25b3930ab50 |
|
| MD5 | 07cf92cf1e5f3c990f67c29c15f3ce60 |
|
| BLAKE2b-256 | 5ac67ee46f7d78600c33daba478ac480d0ee770ed750e4acc055d4c332d74458 |
