Skip to content

Commit 8502145

Browse files
committed
Move metadata routines back into client part of library
1 parent aa324ac commit 8502145

File tree

6 files changed

+6
-6
lines changed

6 files changed

+6
-6
lines changed

func_adl/__init__.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -5,6 +5,7 @@
55

66
# Extra LINQ-like functions
77
from .functions import Range
8+
from .meta_data import extract_metadata # NOQA
89

910
# Main streaming object
1011
from .object_stream import ObjectStream

func_adl/ast/__init__.py

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,5 @@
1-
from .function_simplifier import simplify_chained_calls # NOQA
21
from .aggregate_shortcuts import aggregate_node_transformer # NOQA
32
from .call_stack import argument_stack, stack_frame # NOQA
43
from .func_adl_ast_utils import change_extension_functions_to_calls # NOQA
54
from .func_adl_ast_utils import FuncADLNodeVisitor, function_call # NOQA
6-
from .meta_data import extract_metadata # NOQA
5+
from .function_simplifier import simplify_chained_calls # NOQA
File renamed without changes.

func_adl/object_stream.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -193,7 +193,7 @@ def QMetaData(self, metadata: Dict[str, Any]) -> ObjectStream[T]:
193193
Returns:
194194
ObjectStream[T]: The object stream, with metadata attached
195195
"""
196-
from .ast.meta_data import lookup_query_metadata
196+
from .meta_data import lookup_query_metadata
197197

198198
first = True
199199
base_ast = self.query_ast
@@ -374,7 +374,7 @@ async def value_async(
374374
exe = self._get_executor(executor)
375375

376376
# Run it
377-
from func_adl.ast.meta_data import remove_empty_metadata
377+
from func_adl.meta_data import remove_empty_metadata
378378

379379
return await exe(remove_empty_metadata(self._q_ast), title)
380380

tests/ast/test_meta_data.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,7 @@
22
from typing import Dict, List, Optional
33

44
from func_adl import EventDataset
5-
from func_adl.ast.meta_data import (
5+
from func_adl.meta_data import (
66
extract_metadata,
77
lookup_query_metadata,
88
remove_empty_metadata,

tests/test_object_stream.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -195,7 +195,7 @@ def test_query_metadata_composable(caplog):
195195
r1 = r_base.QMetaData({"two": "2"})
196196
r2 = r_base.QMetaData({"two": "2+"})
197197

198-
from func_adl.ast.meta_data import lookup_query_metadata
198+
from func_adl.meta_data import lookup_query_metadata
199199

200200
assert lookup_query_metadata(r1, "two") == "2"
201201
assert lookup_query_metadata(r2, "two") == "2+"

0 commit comments

Comments
 (0)