Skip to content

Commit 714272a

Browse files
committed
Merge remote-tracking branch 'origin/main' into pytato-array-context-transforms
2 parents 8109e7e + 5eec699 commit 714272a

File tree

1 file changed

+22
-20
lines changed

1 file changed

+22
-20
lines changed

arraycontext/impl/pytato/compile.py

Lines changed: 22 additions & 20 deletions
Original file line numberDiff line numberDiff line change
@@ -46,6 +46,11 @@
4646
class FromActxCompile(Tag):
4747
pass
4848

49+
from pytools import ProcessLogger
50+
51+
import logging
52+
logger = logging.getLogger(__name__)
53+
4954

5055
# {{{ helper classes: AbstractInputDescriptor
5156

@@ -232,26 +237,23 @@ def _as_dict_of_named_arrays(keys, ary):
232237

233238
import loopy as lp
234239

235-
pt_dict_of_named_arrays = self.actx.transform_dag(
236-
pt.make_dict_of_named_arrays(dict_of_named_arrays))
237-
238-
pytato_program = pt.generate_loopy(pt_dict_of_named_arrays,
239-
options=lp.Options(
240-
return_dict=True,
241-
no_numpy=True),
242-
cl_device=self.actx.queue.device)
243-
244-
assert isinstance(pytato_program, BoundPyOpenCLProgram)
245-
246-
pytato_program = (pytato_program
247-
.with_transformed_program(
248-
lambda x: x.with_kernel(
249-
x.default_entrypoint.tagged(FromActxCompile()))))
250-
251-
pytato_program = (pytato_program
252-
.with_transformed_program(self
253-
.actx
254-
.transform_loopy_program))
240+
with ProcessLogger(logger, "transform_dag"):
241+
pt_dict_of_named_arrays = self.actx.transform_dag(
242+
pt.make_dict_of_named_arrays(dict_of_named_arrays))
243+
244+
with ProcessLogger(logger, "generate_loopy"):
245+
pytato_program = pt.generate_loopy(pt_dict_of_named_arrays,
246+
options=lp.Options(
247+
return_dict=True,
248+
no_numpy=True),
249+
cl_device=self.actx.queue.device)
250+
assert isinstance(pytato_program, BoundPyOpenCLProgram)
251+
252+
with ProcessLogger(logger, "transform_loopy_program"):
253+
pytato_program = (pytato_program
254+
.with_transformed_program(self
255+
.actx
256+
.transform_loopy_program))
255257

256258
self.program_cache[arg_id_to_descr] = CompiledFunction(
257259
self.actx, pytato_program,

0 commit comments

Comments
 (0)