lenskit.pipeline.PipelineProfiler#

classlenskit.pipeline.PipelineProfiler(pipeline, file)#

Collect pipeline run statistics for profiling pipeline executions.

Parameters:
writer:csv.DictWriter [str ]#
output:TextIO#
sink_id:uuid.UUID #
set_stages(stages)#
Parameters:

stages (list [str ])

multiprocess()#
Return type:

ProfileSink

close()#
record(record)#
Parameters:

record (dict [str , float ])

run_profiler()#
__enter__()#
__exit__(*args)#