Coverage report: 63%

Files Functions Classes

coverage.py v7.11.0, created at 2025-10-31 10:30 -0600

File class statements missing excluded coverage
src/dataknobs_fsm/api/advanced.py ExecutionMode 0 0 0 100%
src/dataknobs_fsm/api/advanced.py ExecutionHook 0 0 0 100%
src/dataknobs_fsm/api/advanced.py StepResult 0 0 0 100%
src/dataknobs_fsm/api/advanced.py AdvancedFSM 310 80 0 74%
src/dataknobs_fsm/api/advanced.py FSMDebugger 103 50 0 51%
src/dataknobs_fsm/api/advanced.py (no class) 131 2 0 98%
src/dataknobs_fsm/api/async_simple.py AsyncSimpleFSM 95 18 0 81%
src/dataknobs_fsm/api/async_simple.py (no class) 31 1 0 97%
src/dataknobs_fsm/api/simple.py SimpleFSM 64 10 0 84%
src/dataknobs_fsm/api/simple.py (no class) 61 3 0 95%
src/dataknobs_fsm/cli/commands.py (no class) 0 0 0 100%
src/dataknobs_fsm/cli/main.py (no class) 470 215 2 54%
src/dataknobs_fsm/config/builder.py FSMBuilder 241 43 0 82%
src/dataknobs_fsm/config/builder.py FSMBuilder._build_schema.JSONSchemaValidator 27 6 0 78%
src/dataknobs_fsm/config/builder.py (no class) 31 0 0 100%
src/dataknobs_fsm/config/loader.py ConfigLoader 255 94 0 63%
src/dataknobs_fsm/config/loader.py (no class) 26 0 0 100%
src/dataknobs_fsm/config/schema.py ResourceType 0 0 0 100%
src/dataknobs_fsm/config/schema.py ExecutionStrategy 0 0 0 100%
src/dataknobs_fsm/config/schema.py FunctionReference 9 4 0 56%
src/dataknobs_fsm/config/schema.py DataModeConfig 0 0 0 100%
src/dataknobs_fsm/config/schema.py TransactionConfig 0 0 0 100%
src/dataknobs_fsm/config/schema.py StreamConfig 0 0 0 100%
src/dataknobs_fsm/config/schema.py ResourceConfig 0 0 0 100%
src/dataknobs_fsm/config/schema.py ArcConfig 0 0 0 100%
src/dataknobs_fsm/config/schema.py PushArcConfig 0 0 0 100%
src/dataknobs_fsm/config/schema.py StateConfig 8 8 0 0%
src/dataknobs_fsm/config/schema.py NetworkConfig 9 0 0 100%
src/dataknobs_fsm/config/schema.py FSMConfig 13 2 0 85%
src/dataknobs_fsm/config/schema.py UseCaseTemplate 0 0 0 100%
src/dataknobs_fsm/config/schema.py TemplateConfig 0 0 0 100%
src/dataknobs_fsm/config/schema.py (no class) 133 1 0 99%
src/dataknobs_fsm/config/validator.py ConfigValidator 15 0 0 100%
src/dataknobs_fsm/config/validator.py (no class) 8 0 0 100%
src/dataknobs_fsm/core/arc.py DataIsolationMode 0 0 0 100%
src/dataknobs_fsm/core/arc.py ArcDefinition 1 0 0 100%
src/dataknobs_fsm/core/arc.py PushArc 0 0 0 100%
src/dataknobs_fsm/core/arc.py ArcExecution 159 68 0 57%
src/dataknobs_fsm/core/arc.py (no class) 46 0 2 100%
src/dataknobs_fsm/core/context_factory.py ContextFactory 55 12 0 78%
src/dataknobs_fsm/core/context_factory.py (no class) 16 0 0 100%
src/dataknobs_fsm/core/data_modes.py DataHandlingMode 0 0 0 100%
src/dataknobs_fsm/core/data_modes.py DataHandler 1 0 34 100%
src/dataknobs_fsm/core/data_modes.py CopyModeHandler 14 0 0 100%
src/dataknobs_fsm/core/data_modes.py ReferenceModeHandler 32 3 0 91%
src/dataknobs_fsm/core/data_modes.py DirectModeHandler 13 0 0 100%
src/dataknobs_fsm/core/data_modes.py DataModeManager 6 0 0 100%
src/dataknobs_fsm/core/data_modes.py (no class) 37 0 8 100%
src/dataknobs_fsm/core/data_wrapper.py FSMData 46 45 2 2%
src/dataknobs_fsm/core/data_wrapper.py StateDataWrapper 12 3 0 75%
src/dataknobs_fsm/core/data_wrapper.py (no class) 59 10 1 83%
src/dataknobs_fsm/core/exceptions.py FSMError 2 0 0 100%
src/dataknobs_fsm/core/exceptions.py InvalidConfigurationError 0 0 0 100%
src/dataknobs_fsm/core/exceptions.py StateExecutionError 2 0 0 100%
src/dataknobs_fsm/core/exceptions.py TransitionError 3 0 0 100%
src/dataknobs_fsm/core/exceptions.py ResourceError 2 0 0 100%
src/dataknobs_fsm/core/exceptions.py ValidationError 0 0 0 100%
src/dataknobs_fsm/core/exceptions.py FunctionError 6 1 0 83%
src/dataknobs_fsm/core/exceptions.py TimeoutError 0 0 0 100%
src/dataknobs_fsm/core/exceptions.py ConcurrencyError 0 0 0 100%
src/dataknobs_fsm/core/exceptions.py CircuitBreakerError 5 0 0 100%
src/dataknobs_fsm/core/exceptions.py ETLError 0 0 0 100%
src/dataknobs_fsm/core/exceptions.py BulkheadTimeoutError 0 0 0 100%
src/dataknobs_fsm/core/exceptions.py (no class) 25 0 0 100%
src/dataknobs_fsm/core/fsm.py FSM 210 78 0 63%
src/dataknobs_fsm/core/fsm.py (no class) 38 0 0 100%
src/dataknobs_fsm/core/modes.py ProcessingMode 0 0 0 100%
src/dataknobs_fsm/core/modes.py TransactionMode 0 0 0 100%
src/dataknobs_fsm/core/modes.py (no class) 19 0 0 100%
src/dataknobs_fsm/core/network.py Arc 7 2 0 71%
src/dataknobs_fsm/core/network.py NetworkResourceRequirements 11 3 0 73%
src/dataknobs_fsm/core/network.py StateNetwork 169 25 0 85%
src/dataknobs_fsm/core/network.py (no class) 60 0 0 100%
src/dataknobs_fsm/core/result_formatter.py ResultFormatter 22 0 0 100%
src/dataknobs_fsm/core/result_formatter.py (no class) 19 0 0 100%
src/dataknobs_fsm/core/state.py StateType 0 0 0 100%
src/dataknobs_fsm/core/state.py StateStatus 0 0 0 100%
src/dataknobs_fsm/core/state.py StateSchema 14 0 0 100%
src/dataknobs_fsm/core/state.py StateDefinition 12 2 0 83%
src/dataknobs_fsm/core/state.py StateInstance 43 2 0 95%
src/dataknobs_fsm/core/state.py State 4 0 0 100%
src/dataknobs_fsm/core/state.py StateMode 0 0 0 100%
src/dataknobs_fsm/core/state.py (no class) 100 0 2 100%
src/dataknobs_fsm/core/transactions.py TransactionStrategy 0 0 0 100%
src/dataknobs_fsm/core/transactions.py TransactionState 0 0 0 100%
src/dataknobs_fsm/core/transactions.py Transaction 17 2 2 88%
src/dataknobs_fsm/core/transactions.py TransactionManager 20 4 27 80%
src/dataknobs_fsm/core/transactions.py SingleTransactionManager 31 2 0 94%
src/dataknobs_fsm/core/transactions.py BatchTransactionManager 44 11 0 75%
src/dataknobs_fsm/core/transactions.py ManualTransactionManager 37 4 0 89%
src/dataknobs_fsm/core/transactions.py (no class) 61 1 9 98%
src/dataknobs_fsm/execution/async_batch.py AsyncBatchExecutor 83 39 0 53%
src/dataknobs_fsm/execution/async_batch.py (no class) 15 0 0 100%
src/dataknobs_fsm/execution/async_engine.py AsyncExecutionEngine 221 56 0 75%
src/dataknobs_fsm/execution/async_engine.py (no class) 30 0 0 100%
src/dataknobs_fsm/execution/async_stream.py AsyncStreamResult 0 0 0 100%
src/dataknobs_fsm/execution/async_stream.py AsyncStreamExecutor 90 18 0 80%
src/dataknobs_fsm/execution/async_stream.py (no class) 26 0 0 100%
src/dataknobs_fsm/execution/base_engine.py BaseExecutionEngine 66 25 29 62%
src/dataknobs_fsm/execution/base_engine.py (no class) 21 0 12 100%
src/dataknobs_fsm/execution/batch.py BatchResult 0 0 0 100%
src/dataknobs_fsm/execution/batch.py BatchProgress 13 13 0 0%
src/dataknobs_fsm/execution/batch.py BatchExecutor 146 71 0 51%
src/dataknobs_fsm/execution/batch.py (no class) 44 0 0 100%
src/dataknobs_fsm/execution/common.py TransitionSelectionMode 0 0 0 100%
src/dataknobs_fsm/execution/common.py NetworkSelector 42 2 0 95%
src/dataknobs_fsm/execution/common.py ArcScorer 23 0 0 100%
src/dataknobs_fsm/execution/common.py TransitionSelector 67 3 0 96%
src/dataknobs_fsm/execution/common.py (no class) 44 0 2 100%
src/dataknobs_fsm/execution/context.py ResourceStatus 0 0 0 100%
src/dataknobs_fsm/execution/context.py ResourceAllocation 0 0 0 100%
src/dataknobs_fsm/execution/context.py TransactionInfo 0 0 0 100%
src/dataknobs_fsm/execution/context.py ExecutionContext 133 58 0 56%
src/dataknobs_fsm/execution/context.py (no class) 54 0 0 100%
src/dataknobs_fsm/execution/engine.py TraversalStrategy 0 0 0 100%
src/dataknobs_fsm/execution/engine.py ExecutionEngine 322 147 0 54%
src/dataknobs_fsm/execution/engine.py (no class) 46 0 0 100%
src/dataknobs_fsm/execution/history.py ExecutionStatus 0 0 0 100%
src/dataknobs_fsm/execution/history.py ExecutionStep 52 0 0 100%
src/dataknobs_fsm/execution/history.py ExecutionHistory 188 18 0 90%
src/dataknobs_fsm/execution/history.py (no class) 46 0 0 100%
src/dataknobs_fsm/execution/network.py NetworkExecutor 171 77 0 55%
src/dataknobs_fsm/execution/network.py (no class) 18 0 0 100%
src/dataknobs_fsm/execution/stream.py StreamPipeline 0 0 0 100%
src/dataknobs_fsm/execution/stream.py StreamProgress 9 0 0 100%
src/dataknobs_fsm/execution/stream.py StreamExecutor 96 29 0 70%
src/dataknobs_fsm/execution/stream.py (no class) 36 0 0 100%
src/dataknobs_fsm/functions/base.py FunctionType 0 0 0 100%
src/dataknobs_fsm/functions/base.py ExecutionResult 8 2 0 75%
src/dataknobs_fsm/functions/base.py FunctionContext 0 0 0 100%
src/dataknobs_fsm/functions/base.py IValidationFunction 0 0 16 100%
src/dataknobs_fsm/functions/base.py ITransformFunction 0 0 16 100%
src/dataknobs_fsm/functions/base.py IStateTestFunction 0 0 16 100%
src/dataknobs_fsm/functions/base.py IEndStateTestFunction 0 0 16 100%
src/dataknobs_fsm/functions/base.py ResourceStatus 0 0 0 100%
src/dataknobs_fsm/functions/base.py ResourceConfig 0 0 0 100%
src/dataknobs_fsm/functions/base.py IResource 0 0 35 100%
src/dataknobs_fsm/functions/base.py FSMError 0 0 0 100%
src/dataknobs_fsm/functions/base.py ValidationError 2 0 0 100%
src/dataknobs_fsm/functions/base.py TransformError 0 0 0 100%
src/dataknobs_fsm/functions/base.py StateTransitionError 3 0 0 100%
src/dataknobs_fsm/functions/base.py ResourceError 3 0 0 100%
src/dataknobs_fsm/functions/base.py ConfigurationError 0 0 0 100%
src/dataknobs_fsm/functions/base.py BaseFunction 8 0 0 100%
src/dataknobs_fsm/functions/base.py CompositeFunction 8 0 0 100%
src/dataknobs_fsm/functions/base.py Function 0 0 10 100%
src/dataknobs_fsm/functions/base.py FunctionRegistry 35 26 0 26%
src/dataknobs_fsm/functions/base.py (no class) 76 0 30 100%
src/dataknobs_fsm/functions/library/database.py DatabaseFetch 21 16 0 24%
src/dataknobs_fsm/functions/library/database.py DatabaseUpsert 19 14 0 26%
src/dataknobs_fsm/functions/library/database.py BatchCommit 20 20 0 0%
src/dataknobs_fsm/functions/library/database.py DatabaseQuery 17 17 0 0%
src/dataknobs_fsm/functions/library/database.py DatabaseTransaction 24 24 0 0%
src/dataknobs_fsm/functions/library/database.py DatabaseBulkInsert 24 24 0 0%
src/dataknobs_fsm/functions/library/database.py (no class) 39 6 0 85%
src/dataknobs_fsm/functions/library/streaming.py ChunkReader 77 77 0 0%
src/dataknobs_fsm/functions/library/streaming.py RecordParser 50 50 0 0%
src/dataknobs_fsm/functions/library/streaming.py FileAppender 51 51 0 0%
src/dataknobs_fsm/functions/library/streaming.py StreamAggregator 46 46 0 0%
src/dataknobs_fsm/functions/library/streaming.py (no class) 39 39 0 0%
src/dataknobs_fsm/functions/library/transformers.py FieldMapper 31 31 0 0%
src/dataknobs_fsm/functions/library/transformers.py ValueNormalizer 37 37 0 0%
src/dataknobs_fsm/functions/library/transformers.py TypeConverter 24 24 0 0%
src/dataknobs_fsm/functions/library/transformers.py DataEnricher 15 15 0 0%
src/dataknobs_fsm/functions/library/transformers.py FieldFilter 9 9 0 0%
src/dataknobs_fsm/functions/library/transformers.py ValueReplacer 8 8 0 0%
src/dataknobs_fsm/functions/library/transformers.py ArrayFlattener 25 25 0 0%
src/dataknobs_fsm/functions/library/transformers.py DataSplitter 14 14 0 0%
src/dataknobs_fsm/functions/library/transformers.py ChainTransformer 5 5 0 0%
src/dataknobs_fsm/functions/library/transformers.py (no class) 57 9 0 84%
src/dataknobs_fsm/functions/library/validators.py RequiredFieldsValidator 16 16 0 0%
src/dataknobs_fsm/functions/library/validators.py SchemaValidator 18 18 0 0%
src/dataknobs_fsm/functions/library/validators.py RangeValidator 16 16 0 0%
src/dataknobs_fsm/functions/library/validators.py PatternValidator 16 16 0 0%
src/dataknobs_fsm/functions/library/validators.py TypeValidator 20 20 0 0%
src/dataknobs_fsm/functions/library/validators.py LengthValidator 19 19 0 0%
src/dataknobs_fsm/functions/library/validators.py UniqueValidator 28 28 0 0%
src/dataknobs_fsm/functions/library/validators.py DependencyValidator 12 12 0 0%
src/dataknobs_fsm/functions/library/validators.py CompositeValidator 13 13 0 0%
src/dataknobs_fsm/functions/library/validators.py (no class) 48 8 0 83%
src/dataknobs_fsm/functions/manager.py FunctionSource 0 0 0 100%
src/dataknobs_fsm/functions/manager.py AsyncCallable 1 1 0 0%
src/dataknobs_fsm/functions/manager.py FunctionWrapper 31 3 5 90%
src/dataknobs_fsm/functions/manager.py InterfaceWrapper 79 17 0 78%
src/dataknobs_fsm/functions/manager.py FunctionManager 91 3 0 97%
src/dataknobs_fsm/functions/manager.py (no class) 55 0 1 100%
src/dataknobs_fsm/io/adapters.py FileIOAdapter 19 10 0 47%
src/dataknobs_fsm/io/adapters.py AsyncFileProvider 54 22 0 59%
src/dataknobs_fsm/io/adapters.py SyncFileProvider 39 39 0 0%
src/dataknobs_fsm/io/adapters.py DatabaseIOAdapter 9 5 0 44%
src/dataknobs_fsm/io/adapters.py AsyncDatabaseProvider 51 51 0 0%
src/dataknobs_fsm/io/adapters.py SyncDatabaseProvider 59 7 0 88%
src/dataknobs_fsm/io/adapters.py HTTPIOAdapter 9 4 0 56%
src/dataknobs_fsm/io/adapters.py AsyncHTTPProvider 81 78 0 4%
src/dataknobs_fsm/io/adapters.py SyncHTTPProvider 55 1 0 98%
src/dataknobs_fsm/io/adapters.py StreamIOAdapter 9 9 0 0%
src/dataknobs_fsm/io/adapters.py (no class) 98 0 0 100%
src/dataknobs_fsm/io/base.py IOMode 0 0 0 100%
src/dataknobs_fsm/io/base.py IOFormat 0 0 0 100%
src/dataknobs_fsm/io/base.py IOConfig 0 0 0 100%
src/dataknobs_fsm/io/base.py IOProvider 6 4 6 33%
src/dataknobs_fsm/io/base.py AsyncIOProvider 5 2 12 60%
src/dataknobs_fsm/io/base.py SyncIOProvider 2 2 12 0%
src/dataknobs_fsm/io/base.py TransformProtocol 2 2 0 0%
src/dataknobs_fsm/io/base.py IOAdapter 0 0 6 100%
src/dataknobs_fsm/io/base.py (no class) 59 0 36 100%
src/dataknobs_fsm/io/utils.py IORouter 12 12 0 0%
src/dataknobs_fsm/io/utils.py IOBuffer 18 7 0 61%
src/dataknobs_fsm/io/utils.py IOMetrics 10 0 0 100%
src/dataknobs_fsm/io/utils.py ParallelIOExecutor 17 17 0 0%
src/dataknobs_fsm/io/utils.py (no class) 82 4 0 95%
src/dataknobs_fsm/patterns/api_orchestration.py OrchestrationMode 0 0 0 100%
src/dataknobs_fsm/patterns/api_orchestration.py APIEndpoint 0 0 0 100%
src/dataknobs_fsm/patterns/api_orchestration.py APIOrchestrationConfig 0 0 0 100%
src/dataknobs_fsm/patterns/api_orchestration.py RateLimiter 16 16 0 0%
src/dataknobs_fsm/patterns/api_orchestration.py CircuitBreaker 29 29 0 0%
src/dataknobs_fsm/patterns/api_orchestration.py APIOrchestrator 144 144 0 0%
src/dataknobs_fsm/patterns/api_orchestration.py (no class) 92 92 0 0%
src/dataknobs_fsm/patterns/error_recovery.py RecoveryStrategy 0 0 0 100%
src/dataknobs_fsm/patterns/error_recovery.py BackoffStrategy 0 0 0 100%
src/dataknobs_fsm/patterns/error_recovery.py RetryConfig 0 0 0 100%
src/dataknobs_fsm/patterns/error_recovery.py CircuitBreakerConfig 0 0 0 100%
src/dataknobs_fsm/patterns/error_recovery.py FallbackConfig 0 0 0 100%
src/dataknobs_fsm/patterns/error_recovery.py CompensationConfig 0 0 0 100%
src/dataknobs_fsm/patterns/error_recovery.py BulkheadConfig 0 0 0 100%
src/dataknobs_fsm/patterns/error_recovery.py ErrorRecoveryConfig 0 0 0 100%
src/dataknobs_fsm/patterns/error_recovery.py RetryExecutor 44 44 0 0%
src/dataknobs_fsm/patterns/error_recovery.py CircuitBreakerState 0 0 0 100%
src/dataknobs_fsm/patterns/error_recovery.py CircuitBreaker 54 54 0 0%
src/dataknobs_fsm/patterns/error_recovery.py Bulkhead 23 23 0 0%
src/dataknobs_fsm/patterns/error_recovery.py ErrorRecoveryWorkflow 148 148 0 0%
src/dataknobs_fsm/patterns/error_recovery.py (no class) 126 126 0 0%
src/dataknobs_fsm/patterns/etl.py ETLMode 0 0 0 100%
src/dataknobs_fsm/patterns/etl.py ETLConfig 0 0 0 100%
src/dataknobs_fsm/patterns/etl.py DatabaseETL 122 77 0 37%
src/dataknobs_fsm/patterns/etl.py (no class) 75 20 0 73%
src/dataknobs_fsm/patterns/file_processing.py FileFormat 0 0 0 100%
src/dataknobs_fsm/patterns/file_processing.py ProcessingMode 0 0 0 100%
src/dataknobs_fsm/patterns/file_processing.py FileProcessingConfig 0 0 0 100%
src/dataknobs_fsm/patterns/file_processing.py FileProcessor 213 117 0 45%
src/dataknobs_fsm/patterns/file_processing.py (no class) 93 18 0 81%
src/dataknobs_fsm/resources/base.py ResourceStatus 0 0 0 100%
src/dataknobs_fsm/resources/base.py ResourceHealth 0 0 0 100%
src/dataknobs_fsm/resources/base.py ResourceMetrics 19 4 0 79%
src/dataknobs_fsm/resources/base.py IResourceProvider 5 5 0 0%
src/dataknobs_fsm/resources/base.py IResourcePool 5 5 0 0%
src/dataknobs_fsm/resources/base.py BaseResourceProvider 32 26 15 19%
src/dataknobs_fsm/resources/base.py (no class) 58 0 4 100%
src/dataknobs_fsm/resources/database.py DatabaseResourceAdapter 99 90 0 9%
src/dataknobs_fsm/resources/database.py (no class) 24 0 0 100%
src/dataknobs_fsm/resources/filesystem.py FileHandle 9 9 0 0%
src/dataknobs_fsm/resources/filesystem.py FileSystemResource 112 112 0 0%
src/dataknobs_fsm/resources/filesystem.py (no class) 30 30 0 0%
src/dataknobs_fsm/resources/http.py HTTPSession 14 14 0 0%
src/dataknobs_fsm/resources/http.py HTTPServiceResource 122 122 0 0%
src/dataknobs_fsm/resources/http.py (no class) 40 40 0 0%
src/dataknobs_fsm/resources/manager.py ResourceManager 226 107 0 53%
src/dataknobs_fsm/resources/manager.py ResourceManager.create_provider_from_dict.SimpleResourceProvider 12 8 0 33%
src/dataknobs_fsm/resources/manager.py (no class) 36 0 0 100%
src/dataknobs_fsm/resources/pool.py PoolConfig 0 0 0 100%
src/dataknobs_fsm/resources/pool.py PooledResource 4 0 0 100%
src/dataknobs_fsm/resources/pool.py ResourcePool 126 77 0 39%
src/dataknobs_fsm/resources/pool.py (no class) 36 0 0 100%
src/dataknobs_fsm/resources/properties.py PropertiesHandle 25 0 0 100%
src/dataknobs_fsm/resources/properties.py PropertiesResource 65 0 6 100%
src/dataknobs_fsm/resources/properties.py (no class) 23 0 1 100%
src/dataknobs_fsm/storage/base.py StorageBackend 0 0 0 100%
src/dataknobs_fsm/storage/base.py StorageConfig 7 1 0 86%
src/dataknobs_fsm/storage/base.py IHistoryStorage 0 0 79 100%
src/dataknobs_fsm/storage/base.py BaseHistoryStorage 34 24 2 29%
src/dataknobs_fsm/storage/base.py StorageFactory 6 0 0 100%
src/dataknobs_fsm/storage/base.py (no class) 31 0 49 100%
src/dataknobs_fsm/storage/database.py UnifiedDatabaseStorage 153 21 0 86%
src/dataknobs_fsm/storage/database.py (no class) 24 0 2 100%
src/dataknobs_fsm/storage/file.py FileStorage 9 1 0 89%
src/dataknobs_fsm/storage/file.py (no class) 5 0 0 100%
src/dataknobs_fsm/storage/memory.py InMemoryStorage 16 0 0 100%
src/dataknobs_fsm/storage/memory.py (no class) 7 0 0 100%
src/dataknobs_fsm/streaming/core.py StreamStatus 0 0 0 100%
src/dataknobs_fsm/streaming/core.py StreamConfig 0 0 0 100%
src/dataknobs_fsm/streaming/core.py StreamChunk 0 0 0 100%
src/dataknobs_fsm/streaming/core.py StreamMetrics 12 3 0 75%
src/dataknobs_fsm/streaming/core.py IStreamSource 3 3 0 0%
src/dataknobs_fsm/streaming/core.py IStreamSink 3 3 0 0%
src/dataknobs_fsm/streaming/core.py StreamContext 144 48 0 67%
src/dataknobs_fsm/streaming/core.py AsyncStreamContext 56 0 0 100%
src/dataknobs_fsm/streaming/core.py BasicStreamProcessor 33 2 0 94%
src/dataknobs_fsm/streaming/core.py MemoryStreamSource 16 0 0 100%
src/dataknobs_fsm/streaming/core.py MemoryStreamSink 12 0 0 100%
src/dataknobs_fsm/streaming/core.py (no class) 87 0 0 100%
src/dataknobs_fsm/streaming/db_stream.py DatabaseStreamSource 69 19 0 72%
src/dataknobs_fsm/streaming/db_stream.py DatabaseStreamSink 66 19 0 71%
src/dataknobs_fsm/streaming/db_stream.py DatabaseBulkLoader 43 6 0 86%
src/dataknobs_fsm/streaming/db_stream.py (no class) 25 0 0 100%
src/dataknobs_fsm/streaming/file_stream.py FileFormat 10 0 0 100%
src/dataknobs_fsm/streaming/file_stream.py CompressionFormat 3 0 0 100%
src/dataknobs_fsm/streaming/file_stream.py FileStreamSource 86 19 0 78%
src/dataknobs_fsm/streaming/file_stream.py FileStreamSink 97 31 0 68%
src/dataknobs_fsm/streaming/file_stream.py DirectoryStreamSource 43 6 0 86%
src/dataknobs_fsm/streaming/file_stream.py (no class) 42 0 0 100%
src/dataknobs_fsm/utils/file_utils.py (no class) 111 2 0 98%
src/dataknobs_fsm/utils/json_encoder.py FSMJSONEncoder 11 11 0 0%
src/dataknobs_fsm/utils/json_encoder.py (no class) 9 1 0 89%
src/dataknobs_fsm/utils/streaming_file_utils.py StreamingFileReader 117 22 0 81%
src/dataknobs_fsm/utils/streaming_file_utils.py StreamingFileWriter 80 5 0 94%
src/dataknobs_fsm/utils/streaming_file_utils.py StreamingFileProcessor 23 3 0 87%
src/dataknobs_fsm/utils/streaming_file_utils.py (no class) 40 0 0 100%
Total   11410 4233 507 63%

No items found using the specified filter.