| llm_dataset_engine/__init__.py |
(no function) |
6 |
0 |
0 |
100% |
| llm_dataset_engine/adapters/__init__.py |
(no function) |
4 |
0 |
0 |
100% |
| llm_dataset_engine/adapters/checkpoint_storage.py |
CheckpointStorage.save |
1 |
1 |
0 |
0% |
| llm_dataset_engine/adapters/checkpoint_storage.py |
CheckpointStorage.load |
1 |
1 |
0 |
0% |
| llm_dataset_engine/adapters/checkpoint_storage.py |
CheckpointStorage.list_checkpoints |
1 |
1 |
0 |
0% |
| llm_dataset_engine/adapters/checkpoint_storage.py |
CheckpointStorage.delete |
1 |
1 |
0 |
0% |
| llm_dataset_engine/adapters/checkpoint_storage.py |
CheckpointStorage.exists |
1 |
1 |
0 |
0% |
| llm_dataset_engine/adapters/checkpoint_storage.py |
LocalFileCheckpointStorage.__init__ |
3 |
0 |
0 |
100% |
| llm_dataset_engine/adapters/checkpoint_storage.py |
LocalFileCheckpointStorage._get_checkpoint_path |
2 |
2 |
0 |
0% |
| llm_dataset_engine/adapters/checkpoint_storage.py |
LocalFileCheckpointStorage.save |
11 |
11 |
0 |
0% |
| llm_dataset_engine/adapters/checkpoint_storage.py |
LocalFileCheckpointStorage.load |
12 |
12 |
0 |
0% |
| llm_dataset_engine/adapters/checkpoint_storage.py |
LocalFileCheckpointStorage.list_checkpoints |
14 |
10 |
0 |
29% |
| llm_dataset_engine/adapters/checkpoint_storage.py |
LocalFileCheckpointStorage.delete |
8 |
8 |
0 |
0% |
| llm_dataset_engine/adapters/checkpoint_storage.py |
LocalFileCheckpointStorage.exists |
1 |
1 |
0 |
0% |
| llm_dataset_engine/adapters/checkpoint_storage.py |
LocalFileCheckpointStorage.cleanup_old_checkpoints |
11 |
11 |
0 |
0% |
| llm_dataset_engine/adapters/checkpoint_storage.py |
(no function) |
28 |
0 |
0 |
100% |
| llm_dataset_engine/adapters/data_io.py |
DataReader.read |
1 |
1 |
0 |
0% |
| llm_dataset_engine/adapters/data_io.py |
DataReader.read_chunked |
1 |
1 |
0 |
0% |
| llm_dataset_engine/adapters/data_io.py |
CSVReader.__init__ |
3 |
3 |
0 |
0% |
| llm_dataset_engine/adapters/data_io.py |
CSVReader.read |
1 |
1 |
0 |
0% |
| llm_dataset_engine/adapters/data_io.py |
CSVReader.read_chunked |
2 |
2 |
0 |
0% |
| llm_dataset_engine/adapters/data_io.py |
ExcelReader.__init__ |
2 |
2 |
0 |
0% |
| llm_dataset_engine/adapters/data_io.py |
ExcelReader.read |
1 |
1 |
0 |
0% |
| llm_dataset_engine/adapters/data_io.py |
ExcelReader.read_chunked |
3 |
3 |
0 |
0% |
| llm_dataset_engine/adapters/data_io.py |
ParquetReader.__init__ |
1 |
1 |
0 |
0% |
| llm_dataset_engine/adapters/data_io.py |
ParquetReader.read |
1 |
1 |
0 |
0% |
| llm_dataset_engine/adapters/data_io.py |
ParquetReader.read_chunked |
5 |
5 |
0 |
0% |
| llm_dataset_engine/adapters/data_io.py |
DataFrameReader.__init__ |
1 |
1 |
0 |
0% |
| llm_dataset_engine/adapters/data_io.py |
DataFrameReader.read |
1 |
1 |
0 |
0% |
| llm_dataset_engine/adapters/data_io.py |
DataFrameReader.read_chunked |
2 |
2 |
0 |
0% |
| llm_dataset_engine/adapters/data_io.py |
DataWriter.write |
1 |
1 |
0 |
0% |
| llm_dataset_engine/adapters/data_io.py |
DataWriter.atomic_write |
1 |
1 |
0 |
0% |
| llm_dataset_engine/adapters/data_io.py |
CSVWriter.__init__ |
2 |
2 |
0 |
0% |
| llm_dataset_engine/adapters/data_io.py |
CSVWriter.write |
2 |
2 |
0 |
0% |
| llm_dataset_engine/adapters/data_io.py |
CSVWriter.atomic_write |
9 |
9 |
0 |
0% |
| llm_dataset_engine/adapters/data_io.py |
ExcelWriter.write |
2 |
2 |
0 |
0% |
| llm_dataset_engine/adapters/data_io.py |
ExcelWriter.atomic_write |
9 |
9 |
0 |
0% |
| llm_dataset_engine/adapters/data_io.py |
ParquetWriter.write |
2 |
2 |
0 |
0% |
| llm_dataset_engine/adapters/data_io.py |
ParquetWriter.atomic_write |
9 |
9 |
0 |
0% |
| llm_dataset_engine/adapters/data_io.py |
create_data_reader |
17 |
17 |
0 |
0% |
| llm_dataset_engine/adapters/data_io.py |
create_data_writer |
7 |
7 |
0 |
0% |
| llm_dataset_engine/adapters/data_io.py |
(no function) |
45 |
0 |
0 |
100% |
| llm_dataset_engine/adapters/llm_client.py |
LLMClient.__init__ |
4 |
4 |
0 |
0% |
| llm_dataset_engine/adapters/llm_client.py |
LLMClient.invoke |
1 |
1 |
0 |
0% |
| llm_dataset_engine/adapters/llm_client.py |
LLMClient.estimate_tokens |
1 |
1 |
0 |
0% |
| llm_dataset_engine/adapters/llm_client.py |
LLMClient.batch_invoke |
1 |
1 |
0 |
0% |
| llm_dataset_engine/adapters/llm_client.py |
LLMClient.calculate_cost |
3 |
3 |
0 |
0% |
| llm_dataset_engine/adapters/llm_client.py |
OpenAIClient.__init__ |
9 |
9 |
0 |
0% |
| llm_dataset_engine/adapters/llm_client.py |
OpenAIClient.invoke |
8 |
8 |
0 |
0% |
| llm_dataset_engine/adapters/llm_client.py |
OpenAIClient.estimate_tokens |
1 |
1 |
0 |
0% |
| llm_dataset_engine/adapters/llm_client.py |
AzureOpenAIClient.__init__ |
13 |
13 |
0 |
0% |
| llm_dataset_engine/adapters/llm_client.py |
AzureOpenAIClient.invoke |
8 |
8 |
0 |
0% |
| llm_dataset_engine/adapters/llm_client.py |
AzureOpenAIClient.estimate_tokens |
1 |
1 |
0 |
0% |
| llm_dataset_engine/adapters/llm_client.py |
AnthropicClient.__init__ |
6 |
6 |
0 |
0% |
| llm_dataset_engine/adapters/llm_client.py |
AnthropicClient.invoke |
8 |
8 |
0 |
0% |
| llm_dataset_engine/adapters/llm_client.py |
AnthropicClient.estimate_tokens |
1 |
1 |
0 |
0% |
| llm_dataset_engine/adapters/llm_client.py |
GroqClient.__init__ |
6 |
6 |
0 |
0% |
| llm_dataset_engine/adapters/llm_client.py |
GroqClient.invoke |
8 |
8 |
0 |
0% |
| llm_dataset_engine/adapters/llm_client.py |
GroqClient.estimate_tokens |
1 |
1 |
0 |
0% |
| llm_dataset_engine/adapters/llm_client.py |
create_llm_client |
9 |
9 |
0 |
0% |
| llm_dataset_engine/adapters/llm_client.py |
(no function) |
38 |
0 |
0 |
100% |
| llm_dataset_engine/api/__init__.py |
(no function) |
5 |
0 |
0 |
100% |
| llm_dataset_engine/api/dataset_processor.py |
DatasetProcessor.__init__ |
19 |
19 |
0 |
0% |
| llm_dataset_engine/api/dataset_processor.py |
DatasetProcessor.run |
2 |
2 |
0 |
0% |
| llm_dataset_engine/api/dataset_processor.py |
DatasetProcessor.run_sample |
7 |
7 |
0 |
0% |
| llm_dataset_engine/api/dataset_processor.py |
DatasetProcessor.estimate_cost |
2 |
2 |
0 |
0% |
| llm_dataset_engine/api/dataset_processor.py |
(no function) |
8 |
0 |
0 |
100% |
| llm_dataset_engine/api/health_check.py |
HealthCheck.__init__ |
3 |
3 |
0 |
0% |
| llm_dataset_engine/api/health_check.py |
HealthCheck.check |
24 |
24 |
0 |
0% |
| llm_dataset_engine/api/health_check.py |
HealthCheck.is_healthy |
2 |
2 |
0 |
0% |
| llm_dataset_engine/api/health_check.py |
HealthCheck.get_readiness |
2 |
2 |
0 |
0% |
| llm_dataset_engine/api/health_check.py |
(no function) |
10 |
0 |
0 |
100% |
| llm_dataset_engine/api/pipeline.py |
Pipeline.__init__ |
6 |
0 |
0 |
100% |
| llm_dataset_engine/api/pipeline.py |
Pipeline.add_observer |
2 |
2 |
0 |
0% |
| llm_dataset_engine/api/pipeline.py |
Pipeline.validate |
10 |
10 |
0 |
0% |
| llm_dataset_engine/api/pipeline.py |
Pipeline.estimate_cost |
11 |
11 |
0 |
0% |
| llm_dataset_engine/api/pipeline.py |
Pipeline.execute |
28 |
28 |
0 |
0% |
| llm_dataset_engine/api/pipeline.py |
Pipeline._execute_stages |
32 |
32 |
0 |
0% |
| llm_dataset_engine/api/pipeline.py |
Pipeline.execute_async |
3 |
3 |
0 |
0% |
| llm_dataset_engine/api/pipeline.py |
Pipeline.execute_stream |
3 |
3 |
0 |
0% |
| llm_dataset_engine/api/pipeline.py |
Pipeline._execute_stage |
10 |
10 |
0 |
0% |
| llm_dataset_engine/api/pipeline.py |
(no function) |
22 |
0 |
0 |
100% |
| llm_dataset_engine/api/pipeline_builder.py |
PipelineBuilder.__init__ |
7 |
0 |
0 |
100% |
| llm_dataset_engine/api/pipeline_builder.py |
PipelineBuilder.create |
1 |
0 |
0 |
100% |
| llm_dataset_engine/api/pipeline_builder.py |
PipelineBuilder.from_csv |
2 |
0 |
0 |
100% |
| llm_dataset_engine/api/pipeline_builder.py |
PipelineBuilder.from_excel |
2 |
2 |
0 |
0% |
| llm_dataset_engine/api/pipeline_builder.py |
PipelineBuilder.from_parquet |
2 |
2 |
0 |
0% |
| llm_dataset_engine/api/pipeline_builder.py |
PipelineBuilder.from_dataframe |
3 |
0 |
0 |
100% |
| llm_dataset_engine/api/pipeline_builder.py |
PipelineBuilder.with_prompt |
2 |
0 |
0 |
100% |
| llm_dataset_engine/api/pipeline_builder.py |
PipelineBuilder.with_llm |
3 |
0 |
0 |
100% |
| llm_dataset_engine/api/pipeline_builder.py |
PipelineBuilder.with_batch_size |
2 |
0 |
0 |
100% |
| llm_dataset_engine/api/pipeline_builder.py |
PipelineBuilder.with_concurrency |
2 |
0 |
0 |
100% |
| llm_dataset_engine/api/pipeline_builder.py |
PipelineBuilder.with_checkpoint_interval |
2 |
0 |
0 |
100% |
| llm_dataset_engine/api/pipeline_builder.py |
PipelineBuilder.with_rate_limit |
2 |
0 |
0 |
100% |
| llm_dataset_engine/api/pipeline_builder.py |
PipelineBuilder.with_max_budget |
2 |
0 |
0 |
100% |
| llm_dataset_engine/api/pipeline_builder.py |
PipelineBuilder.with_output |
4 |
4 |
0 |
0% |
| llm_dataset_engine/api/pipeline_builder.py |
PipelineBuilder.with_executor |
2 |
2 |
0 |
0% |
| llm_dataset_engine/api/pipeline_builder.py |
PipelineBuilder.with_async_execution |
2 |
2 |
0 |
0% |
| llm_dataset_engine/api/pipeline_builder.py |
PipelineBuilder.with_streaming |
2 |
2 |
0 |
0% |
| llm_dataset_engine/api/pipeline_builder.py |
PipelineBuilder.build |
8 |
0 |
0 |
100% |
| llm_dataset_engine/api/pipeline_builder.py |
(no function) |
27 |
0 |
0 |
100% |
| llm_dataset_engine/cli/__init__.py |
(no function) |
2 |
0 |
0 |
100% |
| llm_dataset_engine/cli/main.py |
cli |
1 |
0 |
0 |
100% |
| llm_dataset_engine/cli/main.py |
process |
73 |
73 |
0 |
0% |
| llm_dataset_engine/cli/main.py |
estimate |
36 |
36 |
0 |
0% |
| llm_dataset_engine/cli/main.py |
resume |
33 |
24 |
0 |
27% |
| llm_dataset_engine/cli/main.py |
validate |
40 |
40 |
0 |
0% |
| llm_dataset_engine/cli/main.py |
list_checkpoints |
22 |
14 |
0 |
36% |
| llm_dataset_engine/cli/main.py |
inspect |
32 |
9 |
0 |
72% |
| llm_dataset_engine/cli/main.py |
(no function) |
52 |
1 |
0 |
98% |
| llm_dataset_engine/config/__init__.py |
(no function) |
2 |
0 |
0 |
100% |
| llm_dataset_engine/config/config_loader.py |
ConfigLoader.from_yaml |
6 |
6 |
0 |
0% |
| llm_dataset_engine/config/config_loader.py |
ConfigLoader.from_json |
6 |
6 |
0 |
0% |
| llm_dataset_engine/config/config_loader.py |
ConfigLoader._dict_to_specifications |
1 |
1 |
0 |
0% |
| llm_dataset_engine/config/config_loader.py |
ConfigLoader.to_yaml |
4 |
4 |
0 |
0% |
| llm_dataset_engine/config/config_loader.py |
ConfigLoader.to_json |
4 |
4 |
0 |
0% |
| llm_dataset_engine/config/config_loader.py |
(no function) |
17 |
0 |
0 |
100% |
| llm_dataset_engine/core/__init__.py |
(no function) |
3 |
0 |
0 |
100% |
| llm_dataset_engine/core/error_handler.py |
ErrorHandler.__init__ |
3 |
3 |
0 |
0% |
| llm_dataset_engine/core/error_handler.py |
ErrorHandler.handle_error |
20 |
20 |
0 |
0% |
| llm_dataset_engine/core/error_handler.py |
ErrorHandler.should_retry |
3 |
3 |
0 |
0% |
| llm_dataset_engine/core/error_handler.py |
(no function) |
21 |
0 |
0 |
100% |
| llm_dataset_engine/core/models.py |
ExecutionResult.duration |
3 |
3 |
0 |
0% |
| llm_dataset_engine/core/models.py |
ExecutionResult.error_rate |
3 |
3 |
0 |
0% |
| llm_dataset_engine/core/models.py |
ValidationResult.add_error |
2 |
2 |
0 |
0% |
| llm_dataset_engine/core/models.py |
ValidationResult.add_warning |
1 |
1 |
0 |
0% |
| llm_dataset_engine/core/models.py |
(no function) |
98 |
0 |
0 |
100% |
| llm_dataset_engine/core/specifications.py |
DatasetSpec.validate_source_path |
3 |
1 |
0 |
67% |
| llm_dataset_engine/core/specifications.py |
DatasetSpec.validate_no_overlap |
7 |
1 |
0 |
86% |
| llm_dataset_engine/core/specifications.py |
PromptSpec.validate_template |
3 |
1 |
0 |
67% |
| llm_dataset_engine/core/specifications.py |
LLMSpec.validate_azure_config |
5 |
5 |
0 |
0% |
| llm_dataset_engine/core/specifications.py |
ProcessingSpec.validate_checkpoint_dir |
1 |
1 |
0 |
0% |
| llm_dataset_engine/core/specifications.py |
OutputSpec.validate_destination_path |
3 |
3 |
0 |
0% |
| llm_dataset_engine/core/specifications.py |
(no function) |
91 |
0 |
0 |
100% |
| llm_dataset_engine/integrations/__init__.py |
(no function) |
1 |
1 |
0 |
0% |
| llm_dataset_engine/integrations/airflow.py |
LLMTransformOperator.__init__ |
9 |
9 |
0 |
0% |
| llm_dataset_engine/integrations/airflow.py |
LLMTransformOperator.execute |
29 |
29 |
0 |
0% |
| llm_dataset_engine/integrations/airflow.py |
(no function) |
19 |
19 |
0 |
0% |
| llm_dataset_engine/integrations/prefect.py |
llm_transform_task |
25 |
25 |
0 |
0% |
| llm_dataset_engine/integrations/prefect.py |
(no function) |
17 |
17 |
0 |
0% |
| llm_dataset_engine/orchestration/__init__.py |
(no function) |
8 |
0 |
0 |
100% |
| llm_dataset_engine/orchestration/async_executor.py |
AsyncExecutor.__init__ |
3 |
3 |
0 |
0% |
| llm_dataset_engine/orchestration/async_executor.py |
AsyncExecutor.execute |
11 |
11 |
0 |
0% |
| llm_dataset_engine/orchestration/async_executor.py |
AsyncExecutor._execute_stages_async |
8 |
8 |
0 |
0% |
| llm_dataset_engine/orchestration/async_executor.py |
AsyncExecutor._invoke_llm_batch_async |
4 |
4 |
0 |
0% |
| llm_dataset_engine/orchestration/async_executor.py |
AsyncExecutor._invoke_llm_batch_async._invoke_one |
5 |
5 |
0 |
0% |
| llm_dataset_engine/orchestration/async_executor.py |
AsyncExecutor.supports_async |
1 |
1 |
0 |
0% |
| llm_dataset_engine/orchestration/async_executor.py |
AsyncExecutor.supports_streaming |
1 |
1 |
0 |
0% |
| llm_dataset_engine/orchestration/async_executor.py |
AsyncExecutor.name |
1 |
1 |
0 |
0% |
| llm_dataset_engine/orchestration/async_executor.py |
(no function) |
20 |
0 |
0 |
100% |
| llm_dataset_engine/orchestration/execution_context.py |
ExecutionContext.update_stage |
1 |
1 |
0 |
0% |
| llm_dataset_engine/orchestration/execution_context.py |
ExecutionContext.update_row |
1 |
1 |
0 |
0% |
| llm_dataset_engine/orchestration/execution_context.py |
ExecutionContext.add_cost |
2 |
2 |
0 |
0% |
| llm_dataset_engine/orchestration/execution_context.py |
ExecutionContext.get_progress |
3 |
3 |
0 |
0% |
| llm_dataset_engine/orchestration/execution_context.py |
ExecutionContext.get_stats |
3 |
3 |
0 |
0% |
| llm_dataset_engine/orchestration/execution_context.py |
ExecutionContext.to_checkpoint |
1 |
1 |
0 |
0% |
| llm_dataset_engine/orchestration/execution_context.py |
ExecutionContext.from_checkpoint |
1 |
1 |
0 |
0% |
| llm_dataset_engine/orchestration/execution_context.py |
(no function) |
28 |
0 |
0 |
100% |
| llm_dataset_engine/orchestration/execution_strategy.py |
ExecutionStrategy.execute |
1 |
1 |
0 |
0% |
| llm_dataset_engine/orchestration/execution_strategy.py |
ExecutionStrategy.supports_async |
1 |
1 |
0 |
0% |
| llm_dataset_engine/orchestration/execution_strategy.py |
ExecutionStrategy.supports_streaming |
1 |
1 |
0 |
0% |
| llm_dataset_engine/orchestration/execution_strategy.py |
ExecutionStrategy.name |
1 |
1 |
0 |
0% |
| llm_dataset_engine/orchestration/execution_strategy.py |
(no function) |
16 |
0 |
0 |
100% |
| llm_dataset_engine/orchestration/observers.py |
ExecutionObserver.on_pipeline_start |
1 |
1 |
0 |
0% |
| llm_dataset_engine/orchestration/observers.py |
ExecutionObserver.on_stage_start |
1 |
1 |
0 |
0% |
| llm_dataset_engine/orchestration/observers.py |
ExecutionObserver.on_stage_complete |
1 |
1 |
0 |
0% |
| llm_dataset_engine/orchestration/observers.py |
ExecutionObserver.on_stage_error |
1 |
1 |
0 |
0% |
| llm_dataset_engine/orchestration/observers.py |
ExecutionObserver.on_pipeline_complete |
1 |
1 |
0 |
0% |
| llm_dataset_engine/orchestration/observers.py |
ExecutionObserver.on_pipeline_error |
1 |
1 |
0 |
0% |
| llm_dataset_engine/orchestration/observers.py |
ProgressBarObserver.__init__ |
1 |
1 |
0 |
0% |
| llm_dataset_engine/orchestration/observers.py |
ProgressBarObserver.on_pipeline_start |
2 |
2 |
0 |
0% |
| llm_dataset_engine/orchestration/observers.py |
ProgressBarObserver.on_stage_start |
2 |
2 |
0 |
0% |
| llm_dataset_engine/orchestration/observers.py |
ProgressBarObserver.on_stage_complete |
3 |
3 |
0 |
0% |
| llm_dataset_engine/orchestration/observers.py |
ProgressBarObserver.on_stage_error |
2 |
2 |
0 |
0% |
| llm_dataset_engine/orchestration/observers.py |
ProgressBarObserver.on_pipeline_complete |
3 |
3 |
0 |
0% |
| llm_dataset_engine/orchestration/observers.py |
ProgressBarObserver.on_pipeline_error |
3 |
3 |
0 |
0% |
| llm_dataset_engine/orchestration/observers.py |
LoggingObserver.__init__ |
1 |
1 |
0 |
0% |
| llm_dataset_engine/orchestration/observers.py |
LoggingObserver.on_pipeline_start |
1 |
1 |
0 |
0% |
| llm_dataset_engine/orchestration/observers.py |
LoggingObserver.on_stage_start |
1 |
1 |
0 |
0% |
| llm_dataset_engine/orchestration/observers.py |
LoggingObserver.on_stage_complete |
1 |
1 |
0 |
0% |
| llm_dataset_engine/orchestration/observers.py |
LoggingObserver.on_stage_error |
1 |
1 |
0 |
0% |
| llm_dataset_engine/orchestration/observers.py |
LoggingObserver.on_pipeline_complete |
1 |
1 |
0 |
0% |
| llm_dataset_engine/orchestration/observers.py |
LoggingObserver.on_pipeline_error |
1 |
1 |
0 |
0% |
| llm_dataset_engine/orchestration/observers.py |
CostTrackingObserver.__init__ |
3 |
3 |
0 |
0% |
| llm_dataset_engine/orchestration/observers.py |
CostTrackingObserver.on_pipeline_start |
1 |
1 |
0 |
0% |
| llm_dataset_engine/orchestration/observers.py |
CostTrackingObserver.on_stage_start |
1 |
1 |
0 |
0% |
| llm_dataset_engine/orchestration/observers.py |
CostTrackingObserver.on_stage_complete |
4 |
4 |
0 |
0% |
| llm_dataset_engine/orchestration/observers.py |
CostTrackingObserver.on_stage_error |
1 |
1 |
0 |
0% |
| llm_dataset_engine/orchestration/observers.py |
CostTrackingObserver.on_pipeline_complete |
1 |
1 |
0 |
0% |
| llm_dataset_engine/orchestration/observers.py |
CostTrackingObserver.on_pipeline_error |
1 |
1 |
0 |
0% |
| llm_dataset_engine/orchestration/observers.py |
(no function) |
44 |
0 |
0 |
100% |
| llm_dataset_engine/orchestration/pipeline_executor.py |
PipelineExecutor.__init__ |
7 |
7 |
0 |
0% |
| llm_dataset_engine/orchestration/pipeline_executor.py |
PipelineExecutor.add_observer |
2 |
2 |
0 |
0% |
| llm_dataset_engine/orchestration/pipeline_executor.py |
PipelineExecutor.execute |
23 |
23 |
0 |
0% |
| llm_dataset_engine/orchestration/pipeline_executor.py |
PipelineExecutor.pause |
6 |
6 |
0 |
0% |
| llm_dataset_engine/orchestration/pipeline_executor.py |
PipelineExecutor.resume |
7 |
7 |
0 |
0% |
| llm_dataset_engine/orchestration/pipeline_executor.py |
PipelineExecutor.cancel |
4 |
4 |
0 |
0% |
| llm_dataset_engine/orchestration/pipeline_executor.py |
PipelineExecutor._initialize_context |
1 |
1 |
0 |
0% |
| llm_dataset_engine/orchestration/pipeline_executor.py |
PipelineExecutor._execute_all_stages |
1 |
1 |
0 |
0% |
| llm_dataset_engine/orchestration/pipeline_executor.py |
PipelineExecutor._create_execution_result |
3 |
3 |
0 |
0% |
| llm_dataset_engine/orchestration/pipeline_executor.py |
PipelineExecutor._notify_pipeline_start |
6 |
6 |
0 |
0% |
| llm_dataset_engine/orchestration/pipeline_executor.py |
PipelineExecutor._notify_pipeline_complete |
6 |
6 |
0 |
0% |
| llm_dataset_engine/orchestration/pipeline_executor.py |
PipelineExecutor._notify_pipeline_error |
6 |
6 |
0 |
0% |
| llm_dataset_engine/orchestration/pipeline_executor.py |
(no function) |
32 |
32 |
0 |
0% |
| llm_dataset_engine/orchestration/state_manager.py |
StateManager.__init__ |
3 |
3 |
0 |
0% |
| llm_dataset_engine/orchestration/state_manager.py |
StateManager.should_checkpoint |
1 |
1 |
0 |
0% |
| llm_dataset_engine/orchestration/state_manager.py |
StateManager.save_checkpoint |
10 |
10 |
0 |
0% |
| llm_dataset_engine/orchestration/state_manager.py |
StateManager.load_checkpoint |
10 |
10 |
0 |
0% |
| llm_dataset_engine/orchestration/state_manager.py |
StateManager.can_resume |
1 |
1 |
0 |
0% |
| llm_dataset_engine/orchestration/state_manager.py |
StateManager.cleanup_checkpoints |
8 |
8 |
0 |
0% |
| llm_dataset_engine/orchestration/state_manager.py |
StateManager.list_checkpoints |
1 |
1 |
0 |
0% |
| llm_dataset_engine/orchestration/state_manager.py |
(no function) |
16 |
0 |
0 |
100% |
| llm_dataset_engine/orchestration/streaming_executor.py |
StreamingExecutor.__init__ |
2 |
2 |
0 |
0% |
| llm_dataset_engine/orchestration/streaming_executor.py |
StreamingExecutor.execute |
12 |
12 |
0 |
0% |
| llm_dataset_engine/orchestration/streaming_executor.py |
StreamingExecutor._read_chunks |
1 |
1 |
0 |
0% |
| llm_dataset_engine/orchestration/streaming_executor.py |
StreamingExecutor._process_chunk |
5 |
5 |
0 |
0% |
| llm_dataset_engine/orchestration/streaming_executor.py |
StreamingExecutor.supports_async |
1 |
1 |
0 |
0% |
| llm_dataset_engine/orchestration/streaming_executor.py |
StreamingExecutor.supports_streaming |
1 |
1 |
0 |
0% |
| llm_dataset_engine/orchestration/streaming_executor.py |
StreamingExecutor.name |
1 |
1 |
0 |
0% |
| llm_dataset_engine/orchestration/streaming_executor.py |
StreamingResult.__init__ |
5 |
5 |
0 |
0% |
| llm_dataset_engine/orchestration/streaming_executor.py |
StreamingResult.add_chunk |
3 |
3 |
0 |
0% |
| llm_dataset_engine/orchestration/streaming_executor.py |
StreamingResult.finalize |
5 |
5 |
0 |
0% |
| llm_dataset_engine/orchestration/streaming_executor.py |
(no function) |
23 |
0 |
0 |
100% |
| llm_dataset_engine/orchestration/sync_executor.py |
SyncExecutor.__init__ |
1 |
0 |
0 |
100% |
| llm_dataset_engine/orchestration/sync_executor.py |
SyncExecutor.execute |
11 |
11 |
0 |
0% |
| llm_dataset_engine/orchestration/sync_executor.py |
SyncExecutor._execute_stages |
1 |
1 |
0 |
0% |
| llm_dataset_engine/orchestration/sync_executor.py |
SyncExecutor.supports_async |
1 |
1 |
0 |
0% |
| llm_dataset_engine/orchestration/sync_executor.py |
SyncExecutor.supports_streaming |
1 |
1 |
0 |
0% |
| llm_dataset_engine/orchestration/sync_executor.py |
SyncExecutor.name |
1 |
1 |
0 |
0% |
| llm_dataset_engine/orchestration/sync_executor.py |
(no function) |
20 |
0 |
0 |
100% |
| llm_dataset_engine/stages/__init__.py |
(no function) |
8 |
0 |
0 |
100% |
| llm_dataset_engine/stages/data_loader_stage.py |
DataLoaderStage.__init__ |
2 |
2 |
0 |
0% |
| llm_dataset_engine/stages/data_loader_stage.py |
DataLoaderStage.process |
12 |
12 |
0 |
0% |
| llm_dataset_engine/stages/data_loader_stage.py |
DataLoaderStage.validate_input |
8 |
8 |
0 |
0% |
| llm_dataset_engine/stages/data_loader_stage.py |
DataLoaderStage.estimate_cost |
1 |
1 |
0 |
0% |
| llm_dataset_engine/stages/data_loader_stage.py |
(no function) |
12 |
0 |
0 |
100% |
| llm_dataset_engine/stages/llm_invocation_stage.py |
LLMInvocationStage.__init__ |
6 |
6 |
0 |
0% |
| llm_dataset_engine/stages/llm_invocation_stage.py |
LLMInvocationStage.process |
12 |
12 |
0 |
0% |
| llm_dataset_engine/stages/llm_invocation_stage.py |
LLMInvocationStage._process_batch_concurrent |
20 |
20 |
0 |
0% |
| llm_dataset_engine/stages/llm_invocation_stage.py |
LLMInvocationStage._invoke_with_retry_and_ratelimit |
2 |
2 |
0 |
0% |
| llm_dataset_engine/stages/llm_invocation_stage.py |
LLMInvocationStage._invoke_with_retry_and_ratelimit._invoke |
10 |
10 |
0 |
0% |
| llm_dataset_engine/stages/llm_invocation_stage.py |
LLMInvocationStage.validate_input |
9 |
9 |
0 |
0% |
| llm_dataset_engine/stages/llm_invocation_stage.py |
LLMInvocationStage.estimate_cost |
10 |
10 |
0 |
0% |
| llm_dataset_engine/stages/llm_invocation_stage.py |
(no function) |
17 |
0 |
0 |
100% |
| llm_dataset_engine/stages/multi_run_stage.py |
AggregationStrategy.aggregate |
1 |
1 |
0 |
0% |
| llm_dataset_engine/stages/multi_run_stage.py |
ConsensusStrategy.aggregate |
5 |
5 |
0 |
0% |
| llm_dataset_engine/stages/multi_run_stage.py |
FirstSuccessStrategy.aggregate |
4 |
4 |
0 |
0% |
| llm_dataset_engine/stages/multi_run_stage.py |
AllStrategy.aggregate |
1 |
1 |
0 |
0% |
| llm_dataset_engine/stages/multi_run_stage.py |
AverageStrategy.aggregate |
3 |
3 |
0 |
0% |
| llm_dataset_engine/stages/multi_run_stage.py |
MultiRunStage.__init__ |
4 |
4 |
0 |
0% |
| llm_dataset_engine/stages/multi_run_stage.py |
MultiRunStage.process |
14 |
14 |
0 |
0% |
| llm_dataset_engine/stages/multi_run_stage.py |
MultiRunStage.validate_input |
1 |
1 |
0 |
0% |
| llm_dataset_engine/stages/multi_run_stage.py |
MultiRunStage.estimate_cost |
2 |
2 |
0 |
0% |
| llm_dataset_engine/stages/multi_run_stage.py |
(no function) |
23 |
0 |
0 |
100% |
| llm_dataset_engine/stages/pipeline_stage.py |
PipelineStage.__init__ |
2 |
2 |
0 |
0% |
| llm_dataset_engine/stages/pipeline_stage.py |
PipelineStage.process |
1 |
1 |
0 |
0% |
| llm_dataset_engine/stages/pipeline_stage.py |
PipelineStage.validate_input |
1 |
1 |
0 |
0% |
| llm_dataset_engine/stages/pipeline_stage.py |
PipelineStage.execute |
19 |
19 |
0 |
0% |
| llm_dataset_engine/stages/pipeline_stage.py |
PipelineStage.before_process |
1 |
1 |
0 |
0% |
| llm_dataset_engine/stages/pipeline_stage.py |
PipelineStage.after_process |
1 |
1 |
0 |
0% |
| llm_dataset_engine/stages/pipeline_stage.py |
PipelineStage.on_error |
1 |
1 |
0 |
0% |
| llm_dataset_engine/stages/pipeline_stage.py |
PipelineStage.estimate_cost |
1 |
1 |
0 |
0% |
| llm_dataset_engine/stages/pipeline_stage.py |
(no function) |
19 |
0 |
0 |
100% |
| llm_dataset_engine/stages/prompt_formatter_stage.py |
PromptFormatterStage.__init__ |
3 |
3 |
0 |
0% |
| llm_dataset_engine/stages/prompt_formatter_stage.py |
PromptFormatterStage.process |
34 |
34 |
0 |
0% |
| llm_dataset_engine/stages/prompt_formatter_stage.py |
PromptFormatterStage._format_few_shot_examples |
7 |
7 |
0 |
0% |
| llm_dataset_engine/stages/prompt_formatter_stage.py |
PromptFormatterStage.validate_input |
11 |
11 |
0 |
0% |
| llm_dataset_engine/stages/prompt_formatter_stage.py |
PromptFormatterStage.estimate_cost |
1 |
1 |
0 |
0% |
| llm_dataset_engine/stages/prompt_formatter_stage.py |
(no function) |
13 |
0 |
0 |
100% |
| llm_dataset_engine/stages/response_parser_stage.py |
ResponseParser.parse |
1 |
1 |
0 |
0% |
| llm_dataset_engine/stages/response_parser_stage.py |
RawTextParser.parse |
1 |
0 |
0 |
100% |
| llm_dataset_engine/stages/response_parser_stage.py |
JSONParser.__init__ |
1 |
0 |
0 |
100% |
| llm_dataset_engine/stages/response_parser_stage.py |
JSONParser.parse |
16 |
4 |
0 |
75% |
| llm_dataset_engine/stages/response_parser_stage.py |
PydanticParser.__init__ |
2 |
0 |
0 |
100% |
| llm_dataset_engine/stages/response_parser_stage.py |
PydanticParser.parse |
9 |
0 |
0 |
100% |
| llm_dataset_engine/stages/response_parser_stage.py |
RegexParser.__init__ |
1 |
0 |
0 |
100% |
| llm_dataset_engine/stages/response_parser_stage.py |
RegexParser.parse |
9 |
0 |
0 |
100% |
| llm_dataset_engine/stages/response_parser_stage.py |
ResponseParserStage.__init__ |
3 |
3 |
0 |
0% |
| llm_dataset_engine/stages/response_parser_stage.py |
ResponseParserStage.process |
23 |
23 |
0 |
0% |
| llm_dataset_engine/stages/response_parser_stage.py |
ResponseParserStage.validate_input |
7 |
7 |
0 |
0% |
| llm_dataset_engine/stages/response_parser_stage.py |
ResponseParserStage.estimate_cost |
1 |
1 |
0 |
0% |
| llm_dataset_engine/stages/response_parser_stage.py |
(no function) |
28 |
0 |
0 |
100% |
| llm_dataset_engine/stages/result_writer_stage.py |
ResultWriterStage.__init__ |
1 |
1 |
0 |
0% |
| llm_dataset_engine/stages/result_writer_stage.py |
ResultWriterStage.process |
10 |
10 |
0 |
0% |
| llm_dataset_engine/stages/result_writer_stage.py |
ResultWriterStage._merge_results |
19 |
19 |
0 |
0% |
| llm_dataset_engine/stages/result_writer_stage.py |
ResultWriterStage.validate_input |
11 |
11 |
0 |
0% |
| llm_dataset_engine/stages/result_writer_stage.py |
ResultWriterStage.estimate_cost |
1 |
1 |
0 |
0% |
| llm_dataset_engine/stages/result_writer_stage.py |
(no function) |
14 |
0 |
0 |
100% |
| llm_dataset_engine/stages/streaming_loader_stage.py |
StreamingDataLoaderStage.__init__ |
2 |
2 |
0 |
0% |
| llm_dataset_engine/stages/streaming_loader_stage.py |
StreamingDataLoaderStage.process |
3 |
3 |
0 |
0% |
| llm_dataset_engine/stages/streaming_loader_stage.py |
StreamingDataLoaderStage.validate_input |
6 |
6 |
0 |
0% |
| llm_dataset_engine/stages/streaming_loader_stage.py |
StreamingDataLoaderStage.estimate_cost |
1 |
1 |
0 |
0% |
| llm_dataset_engine/stages/streaming_loader_stage.py |
(no function) |
12 |
12 |
0 |
0% |
| llm_dataset_engine/utils/__init__.py |
(no function) |
6 |
0 |
0 |
100% |
| llm_dataset_engine/utils/budget_controller.py |
BudgetController.__init__ |
6 |
0 |
0 |
100% |
| llm_dataset_engine/utils/budget_controller.py |
BudgetController.check_budget |
14 |
0 |
0 |
100% |
| llm_dataset_engine/utils/budget_controller.py |
BudgetController.get_remaining |
3 |
1 |
0 |
67% |
| llm_dataset_engine/utils/budget_controller.py |
BudgetController.get_usage_percentage |
3 |
1 |
0 |
67% |
| llm_dataset_engine/utils/budget_controller.py |
BudgetController.can_afford |
3 |
1 |
0 |
67% |
| llm_dataset_engine/utils/budget_controller.py |
(no function) |
12 |
0 |
0 |
100% |
| llm_dataset_engine/utils/cost_tracker.py |
CostTracker.__init__ |
8 |
0 |
0 |
100% |
| llm_dataset_engine/utils/cost_tracker.py |
CostTracker.add |
10 |
0 |
0 |
100% |
| llm_dataset_engine/utils/cost_tracker.py |
CostTracker.calculate_cost |
3 |
0 |
0 |
100% |
| llm_dataset_engine/utils/cost_tracker.py |
CostTracker.total_cost |
2 |
0 |
0 |
100% |
| llm_dataset_engine/utils/cost_tracker.py |
CostTracker.total_tokens |
2 |
0 |
0 |
100% |
| llm_dataset_engine/utils/cost_tracker.py |
CostTracker.input_tokens |
2 |
0 |
0 |
100% |
| llm_dataset_engine/utils/cost_tracker.py |
CostTracker.output_tokens |
2 |
0 |
0 |
100% |
| llm_dataset_engine/utils/cost_tracker.py |
CostTracker.get_estimate |
3 |
0 |
0 |
100% |
| llm_dataset_engine/utils/cost_tracker.py |
CostTracker.reset |
6 |
0 |
0 |
100% |
| llm_dataset_engine/utils/cost_tracker.py |
CostTracker.get_stage_costs |
2 |
0 |
0 |
100% |
| llm_dataset_engine/utils/cost_tracker.py |
(no function) |
27 |
0 |
0 |
100% |
| llm_dataset_engine/utils/logging_utils.py |
configure_logging |
8 |
8 |
0 |
0% |
| llm_dataset_engine/utils/logging_utils.py |
get_logger |
1 |
0 |
0 |
100% |
| llm_dataset_engine/utils/logging_utils.py |
sanitize_for_logging |
10 |
10 |
0 |
0% |
| llm_dataset_engine/utils/logging_utils.py |
(no function) |
7 |
0 |
0 |
100% |
| llm_dataset_engine/utils/metrics_exporter.py |
PrometheusMetrics.__init__ |
8 |
8 |
0 |
0% |
| llm_dataset_engine/utils/metrics_exporter.py |
PrometheusMetrics.start_server |
7 |
7 |
0 |
0% |
| llm_dataset_engine/utils/metrics_exporter.py |
PrometheusMetrics.record_request |
2 |
2 |
0 |
0% |
| llm_dataset_engine/utils/metrics_exporter.py |
PrometheusMetrics.record_cost |
1 |
1 |
0 |
0% |
| llm_dataset_engine/utils/metrics_exporter.py |
PrometheusMetrics.record_error |
1 |
1 |
0 |
0% |
| llm_dataset_engine/utils/metrics_exporter.py |
PrometheusMetrics.record_rows_processed |
1 |
1 |
0 |
0% |
| llm_dataset_engine/utils/metrics_exporter.py |
PrometheusMetrics.record_throughput |
1 |
1 |
0 |
0% |
| llm_dataset_engine/utils/metrics_exporter.py |
(no function) |
11 |
11 |
0 |
0% |
| llm_dataset_engine/utils/rate_limiter.py |
RateLimiter.__init__ |
6 |
0 |
0 |
100% |
| llm_dataset_engine/utils/rate_limiter.py |
RateLimiter.acquire |
12 |
0 |
0 |
100% |
| llm_dataset_engine/utils/rate_limiter.py |
RateLimiter._refill |
5 |
0 |
0 |
100% |
| llm_dataset_engine/utils/rate_limiter.py |
RateLimiter.available_tokens |
3 |
0 |
0 |
100% |
| llm_dataset_engine/utils/rate_limiter.py |
RateLimiter.reset |
3 |
0 |
0 |
100% |
| llm_dataset_engine/utils/rate_limiter.py |
(no function) |
10 |
0 |
0 |
100% |
| llm_dataset_engine/utils/retry_handler.py |
RetryHandler.__init__ |
7 |
1 |
0 |
86% |
| llm_dataset_engine/utils/retry_handler.py |
RetryHandler.execute |
2 |
0 |
0 |
100% |
| llm_dataset_engine/utils/retry_handler.py |
RetryHandler.calculate_delay |
2 |
0 |
0 |
100% |
| llm_dataset_engine/utils/retry_handler.py |
(no function) |
14 |
0 |
0 |
100% |