Coverage report: 21%

Files Functions Classes

coverage.py v7.10.3, created at 2025-08-17 19:59 -0500

File function statements missing excluded coverage
src/dataknobs_data/backends/elasticsearch.py SyncElasticsearchDatabase.__init__ 3 3 0 0%
src/dataknobs_data/backends/elasticsearch.py SyncElasticsearchDatabase.from_config 1 1 0 0%
src/dataknobs_data/backends/elasticsearch.py SyncElasticsearchDatabase.connect 13 13 0 0%
src/dataknobs_data/backends/elasticsearch.py SyncElasticsearchDatabase.close 2 2 0 0%
src/dataknobs_data/backends/elasticsearch.py SyncElasticsearchDatabase._initialize 1 1 0 0%
src/dataknobs_data/backends/elasticsearch.py SyncElasticsearchDatabase._check_connection 2 2 0 0%
src/dataknobs_data/backends/elasticsearch.py SyncElasticsearchDatabase._record_to_doc 5 5 0 0%
src/dataknobs_data/backends/elasticsearch.py SyncElasticsearchDatabase._doc_to_record 3 3 0 0%
src/dataknobs_data/backends/elasticsearch.py SyncElasticsearchDatabase.create 6 6 0 0%
src/dataknobs_data/backends/elasticsearch.py SyncElasticsearchDatabase.read 5 5 0 0%
src/dataknobs_data/backends/elasticsearch.py SyncElasticsearchDatabase.update 3 3 0 0%
src/dataknobs_data/backends/elasticsearch.py SyncElasticsearchDatabase.delete 4 4 0 0%
src/dataknobs_data/backends/elasticsearch.py SyncElasticsearchDatabase.exists 1 1 0 0%
src/dataknobs_data/backends/elasticsearch.py SyncElasticsearchDatabase.upsert 5 5 0 0%
src/dataknobs_data/backends/elasticsearch.py SyncElasticsearchDatabase.create_batch 11 11 0 0%
src/dataknobs_data/backends/elasticsearch.py SyncElasticsearchDatabase.read_batch 5 5 0 0%
src/dataknobs_data/backends/elasticsearch.py SyncElasticsearchDatabase.delete_batch 7 7 0 0%
src/dataknobs_data/backends/elasticsearch.py SyncElasticsearchDatabase.search 79 79 0 0%
src/dataknobs_data/backends/elasticsearch.py SyncElasticsearchDatabase._count_all 2 2 0 0%
src/dataknobs_data/backends/elasticsearch.py SyncElasticsearchDatabase.count 41 41 0 0%
src/dataknobs_data/backends/elasticsearch.py SyncElasticsearchDatabase.clear 6 6 0 0%
src/dataknobs_data/backends/elasticsearch.py SyncElasticsearchDatabase.close 1 1 0 0%
src/dataknobs_data/backends/elasticsearch.py SyncElasticsearchDatabase.stream_read 8 8 0 0%
src/dataknobs_data/backends/elasticsearch.py SyncElasticsearchDatabase.stream_write 1 1 0 0%
src/dataknobs_data/backends/elasticsearch.py (no function) 38 0 0 100%
src/dataknobs_data/backends/elasticsearch_async.py AsyncElasticsearchDatabase.__init__ 7 7 0 0%
src/dataknobs_data/backends/elasticsearch_async.py AsyncElasticsearchDatabase.from_config 1 1 0 0%
src/dataknobs_data/backends/elasticsearch_async.py AsyncElasticsearchDatabase.connect 5 5 0 0%
src/dataknobs_data/backends/elasticsearch_async.py AsyncElasticsearchDatabase.close 3 3 0 0%
src/dataknobs_data/backends/elasticsearch_async.py AsyncElasticsearchDatabase._initialize 1 1 0 0%
src/dataknobs_data/backends/elasticsearch_async.py AsyncElasticsearchDatabase._ensure_index 5 5 0 0%
src/dataknobs_data/backends/elasticsearch_async.py AsyncElasticsearchDatabase._check_connection 2 2 0 0%
src/dataknobs_data/backends/elasticsearch_async.py AsyncElasticsearchDatabase._record_to_doc 4 4 0 0%
src/dataknobs_data/backends/elasticsearch_async.py AsyncElasticsearchDatabase._doc_to_record 7 7 0 0%
src/dataknobs_data/backends/elasticsearch_async.py AsyncElasticsearchDatabase.create 7 7 0 0%
src/dataknobs_data/backends/elasticsearch_async.py AsyncElasticsearchDatabase.create_batch 13 13 0 0%
src/dataknobs_data/backends/elasticsearch_async.py AsyncElasticsearchDatabase.read 6 6 0 0%
src/dataknobs_data/backends/elasticsearch_async.py AsyncElasticsearchDatabase.update 7 7 0 0%
src/dataknobs_data/backends/elasticsearch_async.py AsyncElasticsearchDatabase.delete 6 6 0 0%
src/dataknobs_data/backends/elasticsearch_async.py AsyncElasticsearchDatabase.exists 2 2 0 0%
src/dataknobs_data/backends/elasticsearch_async.py AsyncElasticsearchDatabase.upsert 4 4 0 0%
src/dataknobs_data/backends/elasticsearch_async.py AsyncElasticsearchDatabase.search 55 55 0 0%
src/dataknobs_data/backends/elasticsearch_async.py AsyncElasticsearchDatabase._count_all 3 3 0 0%
src/dataknobs_data/backends/elasticsearch_async.py AsyncElasticsearchDatabase.clear 4 4 0 0%
src/dataknobs_data/backends/elasticsearch_async.py AsyncElasticsearchDatabase.stream_read 22 22 0 0%
src/dataknobs_data/backends/elasticsearch_async.py AsyncElasticsearchDatabase.stream_write 20 20 0 0%
src/dataknobs_data/backends/elasticsearch_async.py AsyncElasticsearchDatabase.stream_write.batch_func 2 2 0 0%
src/dataknobs_data/backends/elasticsearch_async.py AsyncElasticsearchDatabase.stream_write.batch_func 2 2 0 0%
src/dataknobs_data/backends/elasticsearch_async.py AsyncElasticsearchDatabase._write_batch 8 8 0 0%
src/dataknobs_data/backends/elasticsearch_async.py (no function) 41 0 0 100%
src/dataknobs_data/backends/file.py FileLock.__init__ 3 3 0 0%
src/dataknobs_data/backends/file.py FileLock.acquire 15 15 0 0%
src/dataknobs_data/backends/file.py FileLock.release 12 12 0 0%
src/dataknobs_data/backends/file.py FileLock.__enter__ 2 2 0 0%
src/dataknobs_data/backends/file.py FileLock.__exit__ 1 1 0 0%
src/dataknobs_data/backends/file.py FileFormat.load 0 0 1 100%
src/dataknobs_data/backends/file.py FileFormat.save 0 0 1 100%
src/dataknobs_data/backends/file.py JSONFormat.load 26 26 0 0%
src/dataknobs_data/backends/file.py JSONFormat.save 5 5 0 0%
src/dataknobs_data/backends/file.py CSVFormat.load 42 42 0 0%
src/dataknobs_data/backends/file.py CSVFormat.save 37 37 0 0%
src/dataknobs_data/backends/file.py ParquetFormat.load 17 17 0 0%
src/dataknobs_data/backends/file.py ParquetFormat.save 17 17 0 0%
src/dataknobs_data/backends/file.py AsyncFileDatabase.__init__ 19 19 0 0%
src/dataknobs_data/backends/file.py AsyncFileDatabase.from_config 1 1 0 0%
src/dataknobs_data/backends/file.py AsyncFileDatabase.connect 1 1 0 0%
src/dataknobs_data/backends/file.py AsyncFileDatabase._generate_id 1 1 0 0%
src/dataknobs_data/backends/file.py AsyncFileDatabase._load_data 6 6 0 0%
src/dataknobs_data/backends/file.py AsyncFileDatabase._save_data 13 13 0 0%
src/dataknobs_data/backends/file.py AsyncFileDatabase.create 6 6 0 0%
src/dataknobs_data/backends/file.py AsyncFileDatabase.read 4 4 0 0%
src/dataknobs_data/backends/file.py AsyncFileDatabase.update 7 7 0 0%
src/dataknobs_data/backends/file.py AsyncFileDatabase.delete 7 7 0 0%
src/dataknobs_data/backends/file.py AsyncFileDatabase.exists 3 3 0 0%
src/dataknobs_data/backends/file.py AsyncFileDatabase.upsert 5 5 0 0%
src/dataknobs_data/backends/file.py AsyncFileDatabase.search 27 27 0 0%
src/dataknobs_data/backends/file.py AsyncFileDatabase._count_all 3 3 0 0%
src/dataknobs_data/backends/file.py AsyncFileDatabase.clear 5 5 0 0%
src/dataknobs_data/backends/file.py AsyncFileDatabase.create_batch 9 9 0 0%
src/dataknobs_data/backends/file.py AsyncFileDatabase.read_batch 7 7 0 0%
src/dataknobs_data/backends/file.py AsyncFileDatabase.delete_batch 13 13 0 0%
src/dataknobs_data/backends/file.py AsyncFileDatabase.stream_read 8 8 0 0%
src/dataknobs_data/backends/file.py AsyncFileDatabase.stream_write 1 1 0 0%
src/dataknobs_data/backends/file.py SyncFileDatabase.__init__ 19 19 0 0%
src/dataknobs_data/backends/file.py SyncFileDatabase.from_config 1 1 0 0%
src/dataknobs_data/backends/file.py SyncFileDatabase.connect 1 1 0 0%
src/dataknobs_data/backends/file.py SyncFileDatabase._generate_id 1 1 0 0%
src/dataknobs_data/backends/file.py SyncFileDatabase._load_data 6 6 0 0%
src/dataknobs_data/backends/file.py SyncFileDatabase._save_data 13 13 0 0%
src/dataknobs_data/backends/file.py SyncFileDatabase._do_set_data 4 4 0 0%
src/dataknobs_data/backends/file.py SyncFileDatabase.create 5 5 0 0%
src/dataknobs_data/backends/file.py SyncFileDatabase.read 4 4 0 0%
src/dataknobs_data/backends/file.py SyncFileDatabase.update 7 7 0 0%
src/dataknobs_data/backends/file.py SyncFileDatabase.delete 7 7 0 0%
src/dataknobs_data/backends/file.py SyncFileDatabase.exists 3 3 0 0%
src/dataknobs_data/backends/file.py SyncFileDatabase.upsert 5 5 0 0%
src/dataknobs_data/backends/file.py SyncFileDatabase.search 27 27 0 0%
src/dataknobs_data/backends/file.py SyncFileDatabase._count_all 3 3 0 0%
src/dataknobs_data/backends/file.py SyncFileDatabase.clear 5 5 0 0%
src/dataknobs_data/backends/file.py SyncFileDatabase.create_batch 8 8 0 0%
src/dataknobs_data/backends/file.py SyncFileDatabase.read_batch 7 7 0 0%
src/dataknobs_data/backends/file.py SyncFileDatabase.delete_batch 13 13 0 0%
src/dataknobs_data/backends/file.py SyncFileDatabase.stream_read 8 8 0 0%
src/dataknobs_data/backends/file.py SyncFileDatabase.stream_write 17 17 0 0%
src/dataknobs_data/backends/file.py SyncFileDatabase.stream_write.do_write_batch 21 21 0 0%
src/dataknobs_data/backends/file.py (no function) 90 0 0 100%
src/dataknobs_data/backends/memory.py AsyncMemoryDatabase.__init__ 3 3 0 0%
src/dataknobs_data/backends/memory.py AsyncMemoryDatabase.from_config 1 1 0 0%
src/dataknobs_data/backends/memory.py AsyncMemoryDatabase.connect 1 1 0 0%
src/dataknobs_data/backends/memory.py AsyncMemoryDatabase._generate_id 1 1 0 0%
src/dataknobs_data/backends/memory.py AsyncMemoryDatabase.create 4 4 0 0%
src/dataknobs_data/backends/memory.py AsyncMemoryDatabase.read 3 3 0 0%
src/dataknobs_data/backends/memory.py AsyncMemoryDatabase.update 5 5 0 0%
src/dataknobs_data/backends/memory.py AsyncMemoryDatabase.delete 5 5 0 0%
src/dataknobs_data/backends/memory.py AsyncMemoryDatabase.exists 2 2 0 0%
src/dataknobs_data/backends/memory.py AsyncMemoryDatabase.upsert 3 3 0 0%
src/dataknobs_data/backends/memory.py AsyncMemoryDatabase.search 28 28 0 0%
src/dataknobs_data/backends/memory.py AsyncMemoryDatabase._count_all 2 2 0 0%
src/dataknobs_data/backends/memory.py AsyncMemoryDatabase.clear 4 4 0 0%
src/dataknobs_data/backends/memory.py AsyncMemoryDatabase.create_batch 7 7 0 0%
src/dataknobs_data/backends/memory.py AsyncMemoryDatabase.read_batch 6 6 0 0%
src/dataknobs_data/backends/memory.py AsyncMemoryDatabase.delete_batch 8 8 0 0%
src/dataknobs_data/backends/memory.py AsyncMemoryDatabase.stream_read 10 10 0 0%
src/dataknobs_data/backends/memory.py AsyncMemoryDatabase.stream_write 1 1 0 0%
src/dataknobs_data/backends/memory.py SyncMemoryDatabase.__init__ 3 0 0 100%
src/dataknobs_data/backends/memory.py SyncMemoryDatabase.from_config 1 1 0 0%
src/dataknobs_data/backends/memory.py SyncMemoryDatabase.connect 1 1 0 0%
src/dataknobs_data/backends/memory.py SyncMemoryDatabase._generate_id 1 1 0 0%
src/dataknobs_data/backends/memory.py SyncMemoryDatabase.create 4 0 0 100%
src/dataknobs_data/backends/memory.py SyncMemoryDatabase.read 3 3 0 0%
src/dataknobs_data/backends/memory.py SyncMemoryDatabase.update 5 5 0 0%
src/dataknobs_data/backends/memory.py SyncMemoryDatabase.delete 5 5 0 0%
src/dataknobs_data/backends/memory.py SyncMemoryDatabase.exists 2 2 0 0%
src/dataknobs_data/backends/memory.py SyncMemoryDatabase.upsert 3 3 0 0%
src/dataknobs_data/backends/memory.py SyncMemoryDatabase.search 28 10 0 64%
src/dataknobs_data/backends/memory.py SyncMemoryDatabase._count_all 2 2 0 0%
src/dataknobs_data/backends/memory.py SyncMemoryDatabase.clear 4 4 0 0%
src/dataknobs_data/backends/memory.py SyncMemoryDatabase.create_batch 7 7 0 0%
src/dataknobs_data/backends/memory.py SyncMemoryDatabase.read_batch 6 6 0 0%
src/dataknobs_data/backends/memory.py SyncMemoryDatabase.delete_batch 8 8 0 0%
src/dataknobs_data/backends/memory.py SyncMemoryDatabase.stream_read 9 9 0 0%
src/dataknobs_data/backends/memory.py SyncMemoryDatabase.stream_write 1 0 0 100%
src/dataknobs_data/backends/memory.py (no function) 52 0 0 100%
src/dataknobs_data/backends/postgres.py SyncPostgresDatabase.__init__ 3 3 0 0%
src/dataknobs_data/backends/postgres.py SyncPostgresDatabase.from_config 1 1 0 0%
src/dataknobs_data/backends/postgres.py SyncPostgresDatabase.connect 11 11 0 0%
src/dataknobs_data/backends/postgres.py SyncPostgresDatabase.close 2 2 0 0%
src/dataknobs_data/backends/postgres.py SyncPostgresDatabase._initialize 1 1 0 0%
src/dataknobs_data/backends/postgres.py SyncPostgresDatabase._ensure_table 4 4 0 0%
src/dataknobs_data/backends/postgres.py SyncPostgresDatabase._check_connection 2 2 0 0%
src/dataknobs_data/backends/postgres.py SyncPostgresDatabase._record_to_row 4 4 0 0%
src/dataknobs_data/backends/postgres.py SyncPostgresDatabase._row_to_record 9 9 0 0%
src/dataknobs_data/backends/postgres.py SyncPostgresDatabase.create 6 6 0 0%
src/dataknobs_data/backends/postgres.py SyncPostgresDatabase.read 7 7 0 0%
src/dataknobs_data/backends/postgres.py SyncPostgresDatabase.update 5 5 0 0%
src/dataknobs_data/backends/postgres.py SyncPostgresDatabase.delete 4 4 0 0%
src/dataknobs_data/backends/postgres.py SyncPostgresDatabase.exists 4 4 0 0%
src/dataknobs_data/backends/postgres.py SyncPostgresDatabase.upsert 7 7 0 0%
src/dataknobs_data/backends/postgres.py SyncPostgresDatabase.search 94 94 0 0%
src/dataknobs_data/backends/postgres.py SyncPostgresDatabase._count_all 4 4 0 0%
src/dataknobs_data/backends/postgres.py SyncPostgresDatabase.clear 5 5 0 0%
src/dataknobs_data/backends/postgres.py SyncPostgresDatabase.stream_read 29 29 0 0%
src/dataknobs_data/backends/postgres.py SyncPostgresDatabase.stream_write 18 18 0 0%
src/dataknobs_data/backends/postgres.py SyncPostgresDatabase._write_batch 11 11 0 0%
src/dataknobs_data/backends/postgres.py AsyncPostgresDatabase.__init__ 7 7 0 0%
src/dataknobs_data/backends/postgres.py AsyncPostgresDatabase.from_config 1 1 0 0%
src/dataknobs_data/backends/postgres.py AsyncPostgresDatabase.connect 5 5 0 0%
src/dataknobs_data/backends/postgres.py AsyncPostgresDatabase.close 3 3 0 0%
src/dataknobs_data/backends/postgres.py AsyncPostgresDatabase._initialize 1 1 0 0%
src/dataknobs_data/backends/postgres.py AsyncPostgresDatabase._ensure_table 5 5 0 0%
src/dataknobs_data/backends/postgres.py AsyncPostgresDatabase._check_connection 2 2 0 0%
src/dataknobs_data/backends/postgres.py AsyncPostgresDatabase._record_to_row 4 4 0 0%
src/dataknobs_data/backends/postgres.py AsyncPostgresDatabase._row_to_record 9 9 0 0%
src/dataknobs_data/backends/postgres.py AsyncPostgresDatabase.create 7 7 0 0%
src/dataknobs_data/backends/postgres.py AsyncPostgresDatabase.read 7 7 0 0%
src/dataknobs_data/backends/postgres.py AsyncPostgresDatabase.update 6 6 0 0%
src/dataknobs_data/backends/postgres.py AsyncPostgresDatabase.delete 5 5 0 0%
src/dataknobs_data/backends/postgres.py AsyncPostgresDatabase.exists 5 5 0 0%
src/dataknobs_data/backends/postgres.py AsyncPostgresDatabase.upsert 6 6 0 0%
src/dataknobs_data/backends/postgres.py AsyncPostgresDatabase.search 94 94 0 0%
src/dataknobs_data/backends/postgres.py AsyncPostgresDatabase._count_all 5 5 0 0%
src/dataknobs_data/backends/postgres.py AsyncPostgresDatabase.clear 6 6 0 0%
src/dataknobs_data/backends/postgres.py AsyncPostgresDatabase.stream_read 30 30 0 0%
src/dataknobs_data/backends/postgres.py AsyncPostgresDatabase.stream_write 20 20 0 0%
src/dataknobs_data/backends/postgres.py AsyncPostgresDatabase.stream_write.batch_func 2 2 0 0%
src/dataknobs_data/backends/postgres.py AsyncPostgresDatabase.stream_write.batch_func 2 2 0 0%
src/dataknobs_data/backends/postgres.py AsyncPostgresDatabase._write_batch 8 8 0 0%
src/dataknobs_data/backends/postgres.py (no function) 65 0 0 100%
src/dataknobs_data/backends/s3.py SyncS3Database.__init__ 18 18 0 0%
src/dataknobs_data/backends/s3.py SyncS3Database.from_config 1 1 0 0%
src/dataknobs_data/backends/s3.py SyncS3Database.connect 19 19 0 0%
src/dataknobs_data/backends/s3.py SyncS3Database.close 4 4 0 0%
src/dataknobs_data/backends/s3.py SyncS3Database._initialize 1 1 0 0%
src/dataknobs_data/backends/s3.py SyncS3Database._check_connection 2 2 0 0%
src/dataknobs_data/backends/s3.py SyncS3Database._ensure_bucket_exists 11 11 0 0%
src/dataknobs_data/backends/s3.py SyncS3Database._get_object_key 1 1 0 0%
src/dataknobs_data/backends/s3.py SyncS3Database._record_to_s3_object 4 4 0 0%
src/dataknobs_data/backends/s3.py SyncS3Database._s3_object_to_record 3 3 0 0%
src/dataknobs_data/backends/s3.py SyncS3Database.create 14 14 0 0%
src/dataknobs_data/backends/s3.py SyncS3Database.read 11 11 0 0%
src/dataknobs_data/backends/s3.py SyncS3Database.update 20 20 0 0%
src/dataknobs_data/backends/s3.py SyncS3Database.delete 12 12 0 0%
src/dataknobs_data/backends/s3.py SyncS3Database.list_all 13 13 0 0%
src/dataknobs_data/backends/s3.py SyncS3Database.exists 9 9 0 0%
src/dataknobs_data/backends/s3.py SyncS3Database.search 28 28 0 0%
src/dataknobs_data/backends/s3.py SyncS3Database._fetch_and_filter 13 13 0 0%
src/dataknobs_data/backends/s3.py SyncS3Database._count_all 8 8 0 0%
src/dataknobs_data/backends/s3.py SyncS3Database.clear 15 15 0 0%
src/dataknobs_data/backends/s3.py SyncS3Database.stream_read 20 20 0 0%
src/dataknobs_data/backends/s3.py SyncS3Database.stream_write 18 18 0 0%
src/dataknobs_data/backends/s3.py SyncS3Database._write_batch 8 8 0 0%
src/dataknobs_data/backends/s3.py SyncS3Database._write_single 9 9 0 0%
src/dataknobs_data/backends/s3.py (no function) 43 0 0 100%
src/dataknobs_data/backends/s3_async.py AsyncS3Database.__init__ 6 6 0 0%
src/dataknobs_data/backends/s3_async.py AsyncS3Database.from_config 1 1 0 0%
src/dataknobs_data/backends/s3_async.py AsyncS3Database.connect 4 4 0 0%
src/dataknobs_data/backends/s3_async.py AsyncS3Database.close 3 3 0 0%
src/dataknobs_data/backends/s3_async.py AsyncS3Database._initialize 1 1 0 0%
src/dataknobs_data/backends/s3_async.py AsyncS3Database._check_connection 2 2 0 0%
src/dataknobs_data/backends/s3_async.py AsyncS3Database._get_key 3 3 0 0%
src/dataknobs_data/backends/s3_async.py AsyncS3Database._record_to_s3_object 4 4 0 0%
src/dataknobs_data/backends/s3_async.py AsyncS3Database._s3_object_to_record 7 7 0 0%
src/dataknobs_data/backends/s3_async.py AsyncS3Database.create 8 8 0 0%
src/dataknobs_data/backends/s3_async.py AsyncS3Database.read 12 12 0 0%
src/dataknobs_data/backends/s3_async.py AsyncS3Database.update 9 9 0 0%
src/dataknobs_data/backends/s3_async.py AsyncS3Database.delete 8 8 0 0%
src/dataknobs_data/backends/s3_async.py AsyncS3Database.exists 8 8 0 0%
src/dataknobs_data/backends/s3_async.py AsyncS3Database.upsert 7 7 0 0%
src/dataknobs_data/backends/s3_async.py AsyncS3Database.search 33 33 0 0%
src/dataknobs_data/backends/s3_async.py AsyncS3Database._matches_filters 33 33 0 0%
src/dataknobs_data/backends/s3_async.py AsyncS3Database._count_all 13 13 0 0%
src/dataknobs_data/backends/s3_async.py AsyncS3Database.clear 18 18 0 0%
src/dataknobs_data/backends/s3_async.py AsyncS3Database.stream_read 26 26 0 0%
src/dataknobs_data/backends/s3_async.py AsyncS3Database.stream_write 20 20 0 0%
src/dataknobs_data/backends/s3_async.py AsyncS3Database.stream_write.batch_func 2 2 0 0%
src/dataknobs_data/backends/s3_async.py AsyncS3Database.stream_write.batch_func 2 2 0 0%
src/dataknobs_data/backends/s3_async.py AsyncS3Database._write_batch 12 12 0 0%
src/dataknobs_data/backends/s3_async.py AsyncS3Database.list_all 16 16 0 0%
src/dataknobs_data/backends/s3_async.py (no function) 43 0 0 100%
src/dataknobs_data/database.py AsyncDatabase.__init__ 2 2 0 0%
src/dataknobs_data/database.py AsyncDatabase._initialize 1 1 0 0%
src/dataknobs_data/database.py AsyncDatabase.create 0 0 9 100%
src/dataknobs_data/database.py AsyncDatabase.read 0 0 9 100%
src/dataknobs_data/database.py AsyncDatabase.update 0 0 10 100%
src/dataknobs_data/database.py AsyncDatabase.delete 0 0 9 100%
src/dataknobs_data/database.py AsyncDatabase.search 0 0 9 100%
src/dataknobs_data/database.py AsyncDatabase._search_with_complex_query 20 20 0 0%
src/dataknobs_data/database.py AsyncDatabase.exists 0 0 9 100%
src/dataknobs_data/database.py AsyncDatabase.upsert 4 4 0 0%
src/dataknobs_data/database.py AsyncDatabase.create_batch 5 5 0 0%
src/dataknobs_data/database.py AsyncDatabase.read_batch 5 5 0 0%
src/dataknobs_data/database.py AsyncDatabase.delete_batch 5 5 0 0%
src/dataknobs_data/database.py AsyncDatabase.update_batch 5 5 0 0%
src/dataknobs_data/database.py AsyncDatabase.count 4 4 0 0%
src/dataknobs_data/database.py AsyncDatabase._count_all 0 0 2 100%
src/dataknobs_data/database.py AsyncDatabase.clear 0 0 1 100%
src/dataknobs_data/database.py AsyncDatabase.connect 1 1 0 0%
src/dataknobs_data/database.py AsyncDatabase.close 1 1 0 0%
src/dataknobs_data/database.py AsyncDatabase.disconnect 1 1 0 0%
src/dataknobs_data/database.py AsyncDatabase.__aenter__ 2 2 0 0%
src/dataknobs_data/database.py AsyncDatabase.__aexit__ 1 1 0 0%
src/dataknobs_data/database.py AsyncDatabase.stream_read 0 0 12 100%
src/dataknobs_data/database.py AsyncDatabase.stream_write 0 0 12 100%
src/dataknobs_data/database.py AsyncDatabase.stream_transform 6 6 0 0%
src/dataknobs_data/database.py AsyncDatabase.create 7 7 0 0%
src/dataknobs_data/database.py SyncDatabase.__init__ 2 0 0 100%
src/dataknobs_data/database.py SyncDatabase._initialize 1 0 0 100%
src/dataknobs_data/database.py SyncDatabase.create 0 0 2 100%
src/dataknobs_data/database.py SyncDatabase.read 0 0 2 100%
src/dataknobs_data/database.py SyncDatabase.update 0 0 2 100%
src/dataknobs_data/database.py SyncDatabase.delete 0 0 2 100%
src/dataknobs_data/database.py SyncDatabase.search 0 0 2 100%
src/dataknobs_data/database.py SyncDatabase._search_with_complex_query 20 20 0 0%
src/dataknobs_data/database.py SyncDatabase.exists 0 0 2 100%
src/dataknobs_data/database.py SyncDatabase.upsert 4 4 0 0%
src/dataknobs_data/database.py SyncDatabase.create_batch 5 5 0 0%
src/dataknobs_data/database.py SyncDatabase.read_batch 5 5 0 0%
src/dataknobs_data/database.py SyncDatabase.delete_batch 5 5 0 0%
src/dataknobs_data/database.py SyncDatabase.update_batch 5 5 0 0%
src/dataknobs_data/database.py SyncDatabase.count 4 4 0 0%
src/dataknobs_data/database.py SyncDatabase._count_all 0 0 2 100%
src/dataknobs_data/database.py SyncDatabase.clear 0 0 1 100%
src/dataknobs_data/database.py SyncDatabase.connect 1 1 0 0%
src/dataknobs_data/database.py SyncDatabase.close 1 1 0 0%
src/dataknobs_data/database.py SyncDatabase.disconnect 1 1 0 0%
src/dataknobs_data/database.py SyncDatabase.__enter__ 2 2 0 0%
src/dataknobs_data/database.py SyncDatabase.__exit__ 1 1 0 0%
src/dataknobs_data/database.py SyncDatabase.stream_read 0 0 12 100%
src/dataknobs_data/database.py SyncDatabase.stream_write 0 0 12 100%
src/dataknobs_data/database.py SyncDatabase.stream_transform 6 6 0 0%
src/dataknobs_data/database.py SyncDatabase.create 7 7 0 0%
src/dataknobs_data/database.py (no function) 44 0 52 100%
src/dataknobs_data/exceptions.py RecordNotFoundError.__init__ 2 2 0 0%
src/dataknobs_data/exceptions.py RecordValidationError.__init__ 4 4 0 0%
src/dataknobs_data/exceptions.py FieldTypeError.__init__ 4 4 0 0%
src/dataknobs_data/exceptions.py DatabaseConnectionError.__init__ 2 2 0 0%
src/dataknobs_data/exceptions.py DatabaseOperationError.__init__ 2 2 0 0%
src/dataknobs_data/exceptions.py QueryError.__init__ 2 2 0 0%
src/dataknobs_data/exceptions.py SerializationError.__init__ 2 2 0 0%
src/dataknobs_data/exceptions.py DataFormatError.__init__ 2 2 0 0%
src/dataknobs_data/exceptions.py BackendNotFoundError.__init__ 6 6 0 0%
src/dataknobs_data/exceptions.py ConfigurationError.__init__ 2 2 0 0%
src/dataknobs_data/exceptions.py ConcurrencyError.__init__ 1 1 0 0%
src/dataknobs_data/exceptions.py TransactionError.__init__ 1 1 0 0%
src/dataknobs_data/exceptions.py MigrationError.__init__ 3 3 0 0%
src/dataknobs_data/exceptions.py (no function) 30 0 0 100%
src/dataknobs_data/factory.py DatabaseFactory.create 27 27 0 0%
src/dataknobs_data/factory.py DatabaseFactory.get_backend_info 2 2 0 0%
src/dataknobs_data/factory.py AsyncDatabaseFactory.create 17 17 0 0%
src/dataknobs_data/factory.py (no function) 12 0 0 100%
src/dataknobs_data/fields.py Field.__post_init__ 2 0 0 100%
src/dataknobs_data/fields.py Field._detect_type 19 7 0 63%
src/dataknobs_data/fields.py Field.copy 1 1 0 0%
src/dataknobs_data/fields.py Field.validate 7 7 0 0%
src/dataknobs_data/fields.py Field.convert_to 11 11 0 0%
src/dataknobs_data/fields.py Field.to_dict 1 1 0 0%
src/dataknobs_data/fields.py Field.from_dict 4 4 0 0%
src/dataknobs_data/fields.py (no function) 28 0 0 100%
src/dataknobs_data/migration/factory.py MigrationFactory.create 11 11 0 0%
src/dataknobs_data/migration/factory.py MigrationFactory._create_operation 20 20 0 0%
src/dataknobs_data/migration/factory.py MigrationFactory._parse_field_type 8 8 0 0%
src/dataknobs_data/migration/factory.py MigrationFactory._get_transform_function 17 17 0 0%
src/dataknobs_data/migration/factory.py TransformerFactory.create 6 6 0 0%
src/dataknobs_data/migration/factory.py TransformerFactory._add_rule 21 21 0 0%
src/dataknobs_data/migration/factory.py MigratorFactory.create 2 2 0 0%
src/dataknobs_data/migration/factory.py (no function) 21 0 0 100%
src/dataknobs_data/migration/migration.py Migration.__init__ 4 4 0 0%
src/dataknobs_data/migration/migration.py Migration.add 2 2 0 0%
src/dataknobs_data/migration/migration.py Migration.add_many 2 2 0 0%
src/dataknobs_data/migration/migration.py Migration.apply 10 10 0 0%
src/dataknobs_data/migration/migration.py Migration.apply_many 1 1 0 0%
src/dataknobs_data/migration/migration.py Migration.can_reverse 1 1 0 0%
src/dataknobs_data/migration/migration.py Migration.get_affected_fields 17 17 0 0%
src/dataknobs_data/migration/migration.py Migration.validate 12 12 0 0%
src/dataknobs_data/migration/migration.py Migration.__repr__ 0 0 5 100%
src/dataknobs_data/migration/migration.py Migration.__str__ 7 7 0 0%
src/dataknobs_data/migration/migration.py (no function) 13 0 1 100%
src/dataknobs_data/migration/migrator.py Migrator.migrate 34 34 0 0%
src/dataknobs_data/migration/migrator.py Migrator.migrate_stream 17 17 0 0%
src/dataknobs_data/migration/migrator.py Migrator.migrate_stream.transform_stream 19 19 0 0%
src/dataknobs_data/migration/migrator.py Migrator.migrate_parallel 11 11 0 0%
src/dataknobs_data/migration/migrator.py Migrator.migrate_parallel.migrate_partition 2 2 0 0%
src/dataknobs_data/migration/migrator.py Migrator.migrate_async 17 17 0 0%
src/dataknobs_data/migration/migrator.py Migrator.migrate_async.transform_stream 19 19 0 0%
src/dataknobs_data/migration/migrator.py Migrator._write_batch 12 12 0 0%
src/dataknobs_data/migration/migrator.py Migrator.validate_migration 16 16 0 0%
src/dataknobs_data/migration/migrator.py (no function) 17 0 0 100%
src/dataknobs_data/migration/operations.py Operation.apply 0 0 10 100%
src/dataknobs_data/migration/operations.py Operation.reverse 0 0 10 100%
src/dataknobs_data/migration/operations.py Operation.__repr__ 0 0 2 100%
src/dataknobs_data/migration/operations.py AddField.apply 4 4 0 0%
src/dataknobs_data/migration/operations.py AddField.reverse 4 4 0 0%
src/dataknobs_data/migration/operations.py AddField.__repr__ 0 0 1 100%
src/dataknobs_data/migration/operations.py RemoveField.apply 6 6 0 0%
src/dataknobs_data/migration/operations.py RemoveField.reverse 6 6 0 0%
src/dataknobs_data/migration/operations.py RemoveField.__repr__ 0 0 1 100%
src/dataknobs_data/migration/operations.py RenameField.apply 7 7 0 0%
src/dataknobs_data/migration/operations.py RenameField.reverse 7 7 0 0%
src/dataknobs_data/migration/operations.py RenameField.__repr__ 0 0 1 100%
src/dataknobs_data/migration/operations.py TransformField.apply 9 9 0 0%
src/dataknobs_data/migration/operations.py TransformField.reverse 14 14 0 0%
src/dataknobs_data/migration/operations.py TransformField.__repr__ 0 0 1 100%
src/dataknobs_data/migration/operations.py CompositeOperation.apply 4 4 0 0%
src/dataknobs_data/migration/operations.py CompositeOperation.reverse 4 4 0 0%
src/dataknobs_data/migration/operations.py CompositeOperation.add 2 2 0 0%
src/dataknobs_data/migration/operations.py CompositeOperation.__repr__ 0 0 1 100%
src/dataknobs_data/migration/operations.py (no function) 39 0 10 100%
src/dataknobs_data/migration/progress.py MigrationProgress.start 2 2 0 0%
src/dataknobs_data/migration/progress.py MigrationProgress.finish 2 2 0 0%
src/dataknobs_data/migration/progress.py MigrationProgress.duration 4 4 0 0%
src/dataknobs_data/migration/progress.py MigrationProgress.percent 3 3 0 0%
src/dataknobs_data/migration/progress.py MigrationProgress.success_rate 3 3 0 0%
src/dataknobs_data/migration/progress.py MigrationProgress.is_complete 1 1 0 0%
src/dataknobs_data/migration/progress.py MigrationProgress.has_errors 1 1 0 0%
src/dataknobs_data/migration/progress.py MigrationProgress.record_success 3 3 0 0%
src/dataknobs_data/migration/progress.py MigrationProgress.record_failure 8 8 0 0%
src/dataknobs_data/migration/progress.py MigrationProgress.record_skip 4 4 0 0%
src/dataknobs_data/migration/progress.py MigrationProgress.add_warning 2 2 0 0%
src/dataknobs_data/migration/progress.py MigrationProgress.set_metadata 2 2 0 0%
src/dataknobs_data/migration/progress.py MigrationProgress.merge 16 16 0 0%
src/dataknobs_data/migration/progress.py MigrationProgress.get_summary 9 9 0 0%
src/dataknobs_data/migration/progress.py MigrationProgress.to_dict 1 1 0 0%
src/dataknobs_data/migration/progress.py MigrationProgress.__str__ 1 1 0 0%
src/dataknobs_data/migration/progress.py MigrationProgress.__repr__ 0 0 5 100%
src/dataknobs_data/migration/progress.py (no function) 36 0 1 100%
src/dataknobs_data/migration/transformer.py TransformRule.apply 0 0 10 100%
src/dataknobs_data/migration/transformer.py MapRule.apply 13 13 0 0%
src/dataknobs_data/migration/transformer.py ExcludeRule.apply 5 5 0 0%
src/dataknobs_data/migration/transformer.py AddRule.apply 10 10 0 0%
src/dataknobs_data/migration/transformer.py Transformer.__init__ 1 1 0 0%
src/dataknobs_data/migration/transformer.py Transformer.map 2 2 0 0%
src/dataknobs_data/migration/transformer.py Transformer.rename 1 1 0 0%
src/dataknobs_data/migration/transformer.py Transformer.exclude 2 2 0 0%
src/dataknobs_data/migration/transformer.py Transformer.add 2 2 0 0%
src/dataknobs_data/migration/transformer.py Transformer.add_rule 2 2 0 0%
src/dataknobs_data/migration/transformer.py Transformer.transform 8 8 0 0%
src/dataknobs_data/migration/transformer.py Transformer.transform_many 6 6 0 0%
src/dataknobs_data/migration/transformer.py Transformer.clear 2 2 0 0%
src/dataknobs_data/migration/transformer.py Transformer.__len__ 1 1 0 0%
src/dataknobs_data/migration/transformer.py Transformer.__repr__ 0 0 2 100%
src/dataknobs_data/migration/transformer.py (no function) 33 0 3 100%
src/dataknobs_data/pandas/batch_ops.py BatchConfig.__post_init__ 4 4 0 0%
src/dataknobs_data/pandas/batch_ops.py ChunkedProcessor.__init__ 1 1 0 0%
src/dataknobs_data/pandas/batch_ops.py ChunkedProcessor.process_dataframe 7 7 0 0%
src/dataknobs_data/pandas/batch_ops.py ChunkedProcessor.iter_chunks 3 3 0 0%
src/dataknobs_data/pandas/batch_ops.py ChunkedProcessor.read_csv_chunked 5 5 0 0%
src/dataknobs_data/pandas/batch_ops.py BatchOperations.__init__ 3 3 0 0%
src/dataknobs_data/pandas/batch_ops.py BatchOperations.bulk_insert_dataframe 14 14 0 0%
src/dataknobs_data/pandas/batch_ops.py BatchOperations.bulk_insert_dataframe.process_chunk 1 1 0 0%
src/dataknobs_data/pandas/batch_ops.py BatchOperations.query_as_dataframe 6 6 0 0%
src/dataknobs_data/pandas/batch_ops.py BatchOperations.update_from_dataframe 42 42 0 0%
src/dataknobs_data/pandas/batch_ops.py BatchOperations.aggregate 13 13 0 0%
src/dataknobs_data/pandas/batch_ops.py BatchOperations.transform_and_save 8 8 0 0%
src/dataknobs_data/pandas/batch_ops.py BatchOperations._insert_chunk 45 45 0 0%
src/dataknobs_data/pandas/batch_ops.py BatchOperations.export_to_csv 2 2 0 0%
src/dataknobs_data/pandas/batch_ops.py BatchOperations.export_to_parquet 2 2 0 0%
src/dataknobs_data/pandas/batch_ops.py (no function) 38 38 0 0%
src/dataknobs_data/pandas/converter.py ConversionOptions.__post_init__ 4 4 0 0%
src/dataknobs_data/pandas/converter.py ConversionOptions.merge_metadata 6 6 0 0%
src/dataknobs_data/pandas/converter.py DataFrameConverter.__init__ 1 1 0 0%
src/dataknobs_data/pandas/converter.py DataFrameConverter.records_to_dataframe 39 39 0 0%
src/dataknobs_data/pandas/converter.py DataFrameConverter.dataframe_to_records 24 24 0 0%
src/dataknobs_data/pandas/converter.py DataFrameConverter.record_to_series 8 8 0 0%
src/dataknobs_data/pandas/converter.py DataFrameConverter.series_to_record 9 9 0 0%
src/dataknobs_data/pandas/converter.py DataFrameConverter._series_to_record 17 17 0 0%
src/dataknobs_data/pandas/converter.py DataFrameConverter._flatten_json_value 12 12 0 0%
src/dataknobs_data/pandas/converter.py DataFrameConverter.validate_conversion 18 18 0 0%
src/dataknobs_data/pandas/converter.py (no function) 36 36 0 0%
src/dataknobs_data/pandas/metadata.py MetadataHandler.__init__ 1 1 0 0%
src/dataknobs_data/pandas/metadata.py MetadataHandler.extract_metadata_from_records 6 6 0 0%
src/dataknobs_data/pandas/metadata.py MetadataHandler.apply_metadata_to_dataframe 17 17 0 0%
src/dataknobs_data/pandas/metadata.py MetadataHandler.extract_metadata_from_dataframe 14 14 0 0%
src/dataknobs_data/pandas/metadata.py MetadataHandler.create_records_with_metadata 18 18 0 0%
src/dataknobs_data/pandas/metadata.py MetadataHandler._get_all_field_names 4 4 0 0%
src/dataknobs_data/pandas/metadata.py MetadataHandler._get_field_types 6 6 0 0%
src/dataknobs_data/pandas/metadata.py MetadataHandler._extract_record_metadata 1 1 0 0%
src/dataknobs_data/pandas/metadata.py MetadataHandler._extract_field_metadata 6 6 0 0%
src/dataknobs_data/pandas/metadata.py MetadataHandler._get_record_metadata_columns 12 12 0 0%
src/dataknobs_data/pandas/metadata.py MetadataHandler.clean_dataframe_columns 7 7 0 0%
src/dataknobs_data/pandas/metadata.py (no function) 30 30 0 0%
src/dataknobs_data/pandas/type_mapper.py TypeMapper.__init__ 1 1 0 0%
src/dataknobs_data/pandas/type_mapper.py TypeMapper._init_mappings 2 2 0 0%
src/dataknobs_data/pandas/type_mapper.py TypeMapper.field_type_to_pandas 4 4 0 0%
src/dataknobs_data/pandas/type_mapper.py TypeMapper.pandas_to_field_type 18 18 0 0%
src/dataknobs_data/pandas/type_mapper.py TypeMapper.convert_value_to_pandas 6 6 0 0%
src/dataknobs_data/pandas/type_mapper.py TypeMapper.convert_value_from_pandas 11 11 0 0%
src/dataknobs_data/pandas/type_mapper.py TypeMapper.infer_field_type_from_value 24 24 0 0%
src/dataknobs_data/pandas/type_mapper.py TypeMapper.cast_series 9 9 0 0%
src/dataknobs_data/pandas/type_mapper.py TypeMapper._to_datetime 7 7 0 0%
src/dataknobs_data/pandas/type_mapper.py TypeMapper._from_datetime 5 5 0 0%
src/dataknobs_data/pandas/type_mapper.py TypeMapper._to_json_object 6 6 0 0%
src/dataknobs_data/pandas/type_mapper.py TypeMapper._from_json_object 8 8 0 0%
src/dataknobs_data/pandas/type_mapper.py TypeMapper._ensure_json_serializable 10 10 0 0%
src/dataknobs_data/pandas/type_mapper.py TypeMapper.infer_field_type 26 26 0 0%
src/dataknobs_data/pandas/type_mapper.py TypeMapper.get_pandas_dtype 2 2 0 0%
src/dataknobs_data/pandas/type_mapper.py TypeMapper.convert_value 32 32 0 0%
src/dataknobs_data/pandas/type_mapper.py TypeMapper.cast_dataframe_dtypes 10 10 0 0%
src/dataknobs_data/pandas/type_mapper.py TypeMapper.normalize_timezone 5 5 0 0%
src/dataknobs_data/pandas/type_mapper.py TypeMapper.get_optimal_dtype 29 29 0 0%
src/dataknobs_data/pandas/type_mapper.py (no function) 40 40 0 0%
src/dataknobs_data/pooling/base.py PoolProtocol.acquire 1 1 0 0%
src/dataknobs_data/pooling/base.py PoolProtocol.close 1 1 0 0%
src/dataknobs_data/pooling/base.py BasePoolConfig.to_connection_string 0 0 2 100%
src/dataknobs_data/pooling/base.py BasePoolConfig.to_hash_key 0 0 2 100%
src/dataknobs_data/pooling/base.py ConnectionPoolManager.__init__ 3 0 0 100%
src/dataknobs_data/pooling/base.py ConnectionPoolManager.get_pool 22 22 0 0%
src/dataknobs_data/pooling/base.py ConnectionPoolManager._close_pool 23 23 0 0%
src/dataknobs_data/pooling/base.py ConnectionPoolManager.remove_pool 7 7 0 0%
src/dataknobs_data/pooling/base.py ConnectionPoolManager.close_all 2 2 0 0%
src/dataknobs_data/pooling/base.py ConnectionPoolManager.get_pool_count 1 1 0 0%
src/dataknobs_data/pooling/base.py ConnectionPoolManager.get_pool_info 8 8 0 0%
src/dataknobs_data/pooling/base.py ConnectionPoolManager._cleanup_on_exit 11 11 0 0%
src/dataknobs_data/pooling/base.py (no function) 21 0 4 100%
src/dataknobs_data/pooling/elasticsearch.py ElasticsearchPoolConfig.__post_init__ 2 2 0 0%
src/dataknobs_data/pooling/elasticsearch.py ElasticsearchPoolConfig.to_connection_string 1 1 0 0%
src/dataknobs_data/pooling/elasticsearch.py ElasticsearchPoolConfig.to_hash_key 1 1 0 0%
src/dataknobs_data/pooling/elasticsearch.py ElasticsearchPoolConfig.from_dict 10 10 0 0%
src/dataknobs_data/pooling/elasticsearch.py create_async_elasticsearch_client 15 15 0 0%
src/dataknobs_data/pooling/elasticsearch.py validate_elasticsearch_client 2 2 0 0%
src/dataknobs_data/pooling/elasticsearch.py close_elasticsearch_client 5 5 0 0%
src/dataknobs_data/pooling/elasticsearch.py (no function) 22 0 0 100%
src/dataknobs_data/pooling/postgres.py PostgresPoolConfig.to_connection_string 1 1 0 0%
src/dataknobs_data/pooling/postgres.py PostgresPoolConfig.to_hash_key 1 1 0 0%
src/dataknobs_data/pooling/postgres.py PostgresPoolConfig.from_dict 1 1 0 0%
src/dataknobs_data/pooling/postgres.py create_asyncpg_pool 2 2 0 0%
src/dataknobs_data/pooling/postgres.py validate_asyncpg_pool 2 2 0 0%
src/dataknobs_data/pooling/postgres.py (no function) 20 0 0 100%
src/dataknobs_data/pooling/s3.py S3PoolConfig.to_connection_string 1 1 0 0%
src/dataknobs_data/pooling/s3.py S3PoolConfig.to_hash_key 1 1 0 0%
src/dataknobs_data/pooling/s3.py S3PoolConfig.from_dict 1 1 0 0%
src/dataknobs_data/pooling/s3.py create_aioboto3_session 11 11 0 0%
src/dataknobs_data/pooling/s3.py validate_s3_session 2 2 0 0%
src/dataknobs_data/pooling/s3.py (no function) 18 0 0 100%
src/dataknobs_data/query.py Filter.matches 44 28 0 36%
src/dataknobs_data/query.py Filter._compare_values 24 13 0 46%
src/dataknobs_data/query.py Filter.to_dict 1 1 0 0%
src/dataknobs_data/query.py Filter.from_dict 1 1 0 0%
src/dataknobs_data/query.py SortSpec.to_dict 1 1 0 0%
src/dataknobs_data/query.py SortSpec.from_dict 1 1 0 0%
src/dataknobs_data/query.py Query.sort_property 1 1 0 0%
src/dataknobs_data/query.py Query.limit_property 1 1 0 0%
src/dataknobs_data/query.py Query.offset_property 1 1 0 0%
src/dataknobs_data/query.py Query.filter 5 5 0 0%
src/dataknobs_data/query.py Query.sort_by 4 4 0 0%
src/dataknobs_data/query.py Query.sort 1 1 0 0%
src/dataknobs_data/query.py Query.set_limit 2 2 0 0%
src/dataknobs_data/query.py Query.limit 1 1 0 0%
src/dataknobs_data/query.py Query.set_offset 2 2 0 0%
src/dataknobs_data/query.py Query.offset 1 1 0 0%
src/dataknobs_data/query.py Query.select 2 2 0 0%
src/dataknobs_data/query.py Query.clear_filters 2 2 0 0%
src/dataknobs_data/query.py Query.clear_sort 2 2 0 0%
src/dataknobs_data/query.py Query.to_dict 8 8 0 0%
src/dataknobs_data/query.py Query.from_dict 9 9 0 0%
src/dataknobs_data/query.py Query.copy 2 2 0 0%
src/dataknobs_data/query.py Query.or_ 29 29 0 0%
src/dataknobs_data/query.py Query.and_ 6 6 0 0%
src/dataknobs_data/query.py Query.not_ 15 15 0 0%
src/dataknobs_data/query.py (no function) 68 0 0 100%
src/dataknobs_data/query_logic.py Condition.matches 0 0 2 100%
src/dataknobs_data/query_logic.py Condition.to_dict 0 0 2 100%
src/dataknobs_data/query_logic.py Condition.from_dict 0 0 2 100%
src/dataknobs_data/query_logic.py FilterCondition.matches 12 12 0 0%
src/dataknobs_data/query_logic.py FilterCondition.to_dict 1 1 0 0%
src/dataknobs_data/query_logic.py FilterCondition.from_dict 1 1 0 0%
src/dataknobs_data/query_logic.py LogicCondition.matches 9 9 0 0%
src/dataknobs_data/query_logic.py LogicCondition.to_dict 1 1 0 0%
src/dataknobs_data/query_logic.py LogicCondition.from_dict 7 7 0 0%
src/dataknobs_data/query_logic.py condition_from_dict 5 5 0 0%
src/dataknobs_data/query_logic.py QueryBuilder.__init__ 5 5 0 0%
src/dataknobs_data/query_logic.py QueryBuilder.where 7 7 0 0%
src/dataknobs_data/query_logic.py QueryBuilder.and_ 15 15 0 0%
src/dataknobs_data/query_logic.py QueryBuilder.or_ 15 15 0 0%
src/dataknobs_data/query_logic.py QueryBuilder.not_ 11 11 0 0%
src/dataknobs_data/query_logic.py QueryBuilder.sort_by 4 4 0 0%
src/dataknobs_data/query_logic.py QueryBuilder.limit 2 2 0 0%
src/dataknobs_data/query_logic.py QueryBuilder.offset 2 2 0 0%
src/dataknobs_data/query_logic.py QueryBuilder.select 2 2 0 0%
src/dataknobs_data/query_logic.py QueryBuilder.build 1 1 0 0%
src/dataknobs_data/query_logic.py ComplexQuery.matches 3 3 0 0%
src/dataknobs_data/query_logic.py ComplexQuery.to_simple_query 17 17 0 0%
src/dataknobs_data/query_logic.py ComplexQuery.to_dict 12 12 0 0%
src/dataknobs_data/query_logic.py ComplexQuery.from_dict 8 8 0 0%
src/dataknobs_data/query_logic.py (no function) 49 0 7 100%
src/dataknobs_data/records.py Record.__init__ 23 10 0 57%
src/dataknobs_data/records.py Record.id 13 7 0 46%
src/dataknobs_data/records.py Record.id 9 9 0 0%
src/dataknobs_data/records.py Record.generate_id 3 3 0 0%
src/dataknobs_data/records.py Record.get_field 1 0 0 100%
src/dataknobs_data/records.py Record.get_value 4 0 0 100%
src/dataknobs_data/records.py Record.get_nested_value 20 14 0 30%
src/dataknobs_data/records.py Record._traverse_dict 7 1 0 86%
src/dataknobs_data/records.py Record.set_field 1 1 0 0%
src/dataknobs_data/records.py Record.remove_field 4 4 0 0%
src/dataknobs_data/records.py Record.has_field 1 1 0 0%
src/dataknobs_data/records.py Record.field_names 1 1 0 0%
src/dataknobs_data/records.py Record.field_count 1 1 0 0%
src/dataknobs_data/records.py Record.__getitem__ 10 10 0 0%
src/dataknobs_data/records.py Record.__setitem__ 3 3 0 0%
src/dataknobs_data/records.py Record.__delitem__ 3 3 0 0%
src/dataknobs_data/records.py Record.__contains__ 1 1 0 0%
src/dataknobs_data/records.py Record.__iter__ 1 1 0 0%
src/dataknobs_data/records.py Record.__len__ 1 0 0 100%
src/dataknobs_data/records.py Record.validate 1 1 0 0%
src/dataknobs_data/records.py Record.get_field_object 3 3 0 0%
src/dataknobs_data/records.py Record.__getattr__ 5 3 0 40%
src/dataknobs_data/records.py Record.__setattr__ 7 5 0 29%
src/dataknobs_data/records.py Record.to_dict 14 8 0 43%
src/dataknobs_data/records.py Record.from_dict 11 11 0 0%
src/dataknobs_data/records.py Record.copy 9 2 0 78%
src/dataknobs_data/records.py Record.project 5 5 0 0%
src/dataknobs_data/records.py Record.merge 9 9 0 0%
src/dataknobs_data/records.py (no function) 42 0 0 100%
src/dataknobs_data/streaming.py StreamConfig.__post_init__ 6 3 0 50%
src/dataknobs_data/streaming.py StreamResult.success_rate 3 3 0 0%
src/dataknobs_data/streaming.py StreamResult.add_error 3 0 0 100%
src/dataknobs_data/streaming.py StreamResult.merge 7 7 0 0%
src/dataknobs_data/streaming.py StreamResult.__str__ 1 1 0 0%
src/dataknobs_data/streaming.py process_batch_with_fallback 27 10 0 63%
src/dataknobs_data/streaming.py async_process_batch_with_fallback 27 27 0 0%
src/dataknobs_data/streaming.py StreamProcessor.batch_iterator 8 8 0 0%
src/dataknobs_data/streaming.py StreamProcessor.list_to_iterator 2 2 0 0%
src/dataknobs_data/streaming.py StreamProcessor.list_to_async_iterator 2 2 0 0%
src/dataknobs_data/streaming.py StreamProcessor.iterator_to_async_iterator 2 2 0 0%
src/dataknobs_data/streaming.py StreamProcessor.async_batch_iterator 8 8 0 0%
src/dataknobs_data/streaming.py StreamProcessor.filter_stream 3 3 0 0%
src/dataknobs_data/streaming.py StreamProcessor.async_filter_stream 3 3 0 0%
src/dataknobs_data/streaming.py StreamProcessor.transform_stream 4 4 0 0%
src/dataknobs_data/streaming.py StreamProcessor.async_transform_stream 4 4 0 0%
src/dataknobs_data/streaming.py StreamingMixin._default_stream_read 9 9 0 0%
src/dataknobs_data/streaming.py StreamingMixin._default_stream_write 19 3 0 84%
src/dataknobs_data/streaming.py AsyncStreamingMixin._default_stream_read 9 9 0 0%
src/dataknobs_data/streaming.py AsyncStreamingMixin._default_stream_write 19 19 0 0%
src/dataknobs_data/streaming.py (no function) 52 0 2 100%
src/dataknobs_data/validation/coercer.py Coercer.coerce 11 11 0 0%
src/dataknobs_data/validation/coercer.py Coercer._field_type_to_python 2 2 0 0%
src/dataknobs_data/validation/coercer.py Coercer._type_name 7 7 0 0%
src/dataknobs_data/validation/coercer.py Coercer._coerce_value 99 99 0 0%
src/dataknobs_data/validation/coercer.py Coercer.coerce_many 6 6 0 0%
src/dataknobs_data/validation/coercer.py (no function) 11 0 0 100%
src/dataknobs_data/validation/constraints.py Constraint.check 0 0 11 100%
src/dataknobs_data/validation/constraints.py Constraint.__and__ 5 5 0 0%
src/dataknobs_data/validation/constraints.py Constraint.__or__ 5 5 0 0%
src/dataknobs_data/validation/constraints.py Constraint.__invert__ 1 1 0 0%
src/dataknobs_data/validation/constraints.py All.__init__ 1 1 0 0%
src/dataknobs_data/validation/constraints.py All.check 6 6 0 0%
src/dataknobs_data/validation/constraints.py Any.__init__ 1 1 0 0%
src/dataknobs_data/validation/constraints.py Any.check 7 7 0 0%
src/dataknobs_data/validation/constraints.py Not.__init__ 1 1 0 0%
src/dataknobs_data/validation/constraints.py Not.check 4 4 0 0%
src/dataknobs_data/validation/constraints.py Required.__init__ 1 1 0 0%
src/dataknobs_data/validation/constraints.py Required.check 6 6 0 0%
src/dataknobs_data/validation/constraints.py Range.__init__ 4 4 0 0%
src/dataknobs_data/validation/constraints.py Range.check 14 14 0 0%
src/dataknobs_data/validation/constraints.py Length.__init__ 8 8 0 0%
src/dataknobs_data/validation/constraints.py Length.check 13 13 0 0%
src/dataknobs_data/validation/constraints.py Pattern.__init__ 4 4 0 0%
src/dataknobs_data/validation/constraints.py Pattern.check 7 7 0 0%
src/dataknobs_data/validation/constraints.py Enum.__init__ 4 4 0 0%
src/dataknobs_data/validation/constraints.py Enum.check 5 5 0 0%
src/dataknobs_data/validation/constraints.py Unique.__init__ 1 1 0 0%
src/dataknobs_data/validation/constraints.py Unique.check 8 8 0 0%
src/dataknobs_data/validation/constraints.py Custom.__init__ 2 2 0 0%
src/dataknobs_data/validation/constraints.py Custom.check 11 11 0 0%
src/dataknobs_data/validation/constraints.py (no function) 40 0 2 100%
src/dataknobs_data/validation/factory.py SchemaFactory.create 11 11 0 0%
src/dataknobs_data/validation/factory.py SchemaFactory._add_field_to_schema 11 11 0 0%
src/dataknobs_data/validation/factory.py SchemaFactory._build_constraints 29 29 0 0%
src/dataknobs_data/validation/factory.py CoercerFactory.create 2 2 0 0%
src/dataknobs_data/validation/factory.py (no function) 15 0 0 100%
src/dataknobs_data/validation/result.py ValidationResult.__bool__ 1 1 0 0%
src/dataknobs_data/validation/result.py ValidationResult.merge 1 1 0 0%
src/dataknobs_data/validation/result.py ValidationResult.add_error 3 3 0 0%
src/dataknobs_data/validation/result.py ValidationResult.add_warning 2 2 0 0%
src/dataknobs_data/validation/result.py ValidationResult.success 1 1 0 0%
src/dataknobs_data/validation/result.py ValidationResult.failure 1 1 0 0%
src/dataknobs_data/validation/result.py ValidationContext.has_seen 1 1 0 0%
src/dataknobs_data/validation/result.py ValidationContext.mark_seen 3 3 0 0%
src/dataknobs_data/validation/result.py ValidationContext.clear 3 3 0 0%
src/dataknobs_data/validation/result.py ValidationContext.set_metadata 1 1 0 0%
src/dataknobs_data/validation/result.py ValidationContext.get_metadata 1 1 0 0%
src/dataknobs_data/validation/result.py (no function) 25 0 0 100%
src/dataknobs_data/validation/schema.py Field.add_constraint 2 2 0 0%
src/dataknobs_data/validation/schema.py Field.validate 21 21 0 0%
src/dataknobs_data/validation/schema.py Field._is_correct_type 7 7 0 0%
src/dataknobs_data/validation/schema.py Schema.__init__ 4 4 0 0%
src/dataknobs_data/validation/schema.py Schema.field 10 10 0 0%
src/dataknobs_data/validation/schema.py Schema.with_description 2 2 0 0%
src/dataknobs_data/validation/schema.py Schema.validate 22 22 0 0%
src/dataknobs_data/validation/schema.py Schema.validate_many 8 8 0 0%
src/dataknobs_data/validation/schema.py Schema.to_dict 1 1 0 0%
src/dataknobs_data/validation/schema.py Schema.from_dict 6 6 0 0%
src/dataknobs_data/validation/schema.py (no function) 27 0 0 100%
Total   5812 4591 275 21%

No items found using the specified filter.