Implement sync get()

[martindurant]

@pfackeldey : as stands, pytest runs on my system and master dask, with

171 failed, 457 passed, 5 skipped, 22 xfailed, 2 warnings

[martindurant]

Update:

24 failed, 604 passed, 5 skipped, 22 xfailed, 2 warnings

[martindurant]

Update:

15 failed, 613 passed, 5 skipped, 22 xfailed, 2 warnings

[pfackeldey]

I can't push to your branch, but this patch:

diff --git a/src/dask_awkward/lib/core.py b/src/dask_awkward/lib/core.py
index 4139b2e..ed1714b 100644
--- a/src/dask_awkward/lib/core.py
+++ b/src/dask_awkward/lib/core.py
@@ -1815,7 +1815,7 @@ def compute_typetracer(dsk: HighLevelGraph, name: str) -> ak.Array:
     return typetracer_array(
         Delayed(
             key,
-            dsk.cull({key}),
+            dsk.cull_layers({name}),
             layer=name,
         ).compute()
     )

brings it further down to:

8 failed, 621 passed, 4 skipped, 22 xfailed, 2 warnings

[martindurant]

I changed it locally and it didn't seem to make any difference to me? I notice that the CI run "conda Tests / pytest (macos-latest, 3.11)" also shows only 8 failures, so perhaps my environment isn't quite right.

Strange that you can't push to this branch - is there some permission I can give? I do have "Maintainers are allowed to edit this pull request" set.

[pfackeldey]

Strange that you can't push to this branch - is there some permission I can give? I do have "Maintainers are allowed to edit this pull request" set.

I'll try a fresh setup soon for me, I'm sure I'm doing something wrong here...

[martindurant]

@pfackeldey

7 failed, 621 passed, 5 skipped, 22 xfailed, 2 warnings

with latest

(reports 9 failed in CI)

[martindurant]

The ramaining problem is recursion: the arguments are not being followed all the way down or classic-task-like (func, arg, arg, ...) not getting called. Probably, _get_sync and _unwind should be one recursive function, but I can't quite phrase it right.