datahub

config

fix(config-parsing): add support for variable expansion for in variables in between string (#4350 )

2022-03-08 12:24:08 -08:00

data_lake

feat(ingest): data-lake - remove spark requirement if not profiling (#4131 )

2022-02-24 23:26:06 -08:00

glue

feat(ingestion): Add Iceberg source (#5010 )

2022-05-26 08:05:57 -07:00

sagemaker

feat(ingest): data-lake - remove spark requirement if not profiling (#4131 )

2022-02-24 23:26:06 -08:00

serde

fix(cli): Bumping avro-gen3 to 0.7.4 (#5098 )

2022-06-07 12:56:06 -07:00

stateful_ingestion

feat(ingestion): Kafka stateful ingestion (#4028 )

2022-02-15 07:18:36 -08:00

__init__.py

feat(ingest): add support for Glue ETL jobs (#2687 )

2021-06-22 11:33:22 -07:00

test_airflow.py

feat(ingest): airflow - add support to capture airflow executions, add high level dataflow jobs api to python sdk (#4615 )

2022-04-12 23:19:39 -07:00

test_allow_deny.py

fix(ingest): apply case insensitive regex matching by default (#3067 )

2021-08-10 10:35:57 -07:00

test_apis.py

fix(ingest): enable mypy disallow_incomplete_defs and disallow_untyped_decorators (#2393 )

2021-04-14 13:40:24 -07:00

test_athena_source.py

chore: fix lint and remove incorrect integration mark from unit tests (#4621 )

2022-04-08 17:18:48 +02:00

test_bigquery_source.py

fix(bigquery): fix lineage bug, improve docs, add dataset filter config (#4607 )

2022-04-07 13:10:21 -07:00

test_bigquery_sql_lineage.py

fix(bigquery): improve handling of extracted audit log sql queries (#4735 )

2022-05-03 14:43:23 +05:30

test_bigquery_sql_parser.py

fix(parsing): incorrect parsing for commas (#5027 )

2022-05-27 22:22:13 +05:30

test_bigquery_usage_source.py

refactor(ingest): bigquery-usage - Adding tests for bigquery usage filters (#5195 )

2022-06-20 18:28:27 -07:00

test_bq_get_partition_range.py

fix(ingest): bigquery - Fix BigQuery Datetime/Timestamp type column partition table profile bug (#4658 )

2022-04-26 16:54:19 +02:00

test_check.py

refactor(test): replace CliRunner with run_datahub_cmd method (#3746 )

2021-12-16 20:07:38 -08:00

test_cli_utils.py

fix(cli): correct handling of env variables (#5203 )

2022-06-20 20:53:47 +05:30

test_clickhouse_source.py

chore: fix lint and remove incorrect integration mark from unit tests (#4621 )

2022-04-08 17:18:48 +02:00

test_config_clean.py

feat(ingestion): improve logging, docs for bigquery, snowflake, redshift (#4344 )

2022-03-14 08:50:29 -07:00

test_confluent_schema_registry.py

feat(ingestion): Support pluggable Schema Registry for Kafka Source (#4535 )

2022-03-30 13:20:23 -07:00

test_corp_group_urn.py

feat(ingest): add python utility classes for NotebookUrn, CorpuserUrn and CorpGroupUrn (#4469 )

2022-03-23 16:07:57 -07:00

test_corpuser_urn.py

feat(ingest): add python utility classes for NotebookUrn, CorpuserUrn and CorpGroupUrn (#4469 )

2022-03-23 16:07:57 -07:00

test_csv_enricher_source.py

feat(ingest): adds csv enricher ingestion source (#5221 )

2022-06-22 12:25:39 +05:30

test_data_flow_urn.py

feat(ingest): add Urn python library for DataJob, DataFlow, Domain and Tag (#4618 )

2022-04-12 09:02:28 +02:00

test_data_job_urn.py

feat(ingest): add Urn python library for DataJob, DataFlow, Domain and Tag (#4618 )

2022-04-12 09:02:28 +02:00

test_data_process_instance_urn.py

feat(ingest): airflow - add support to capture airflow executions, add high level dataflow jobs api to python sdk (#4615 )

2022-04-12 23:19:39 -07:00

test_dataset_urn.py

feat(ingest): lib - add better support for working with urns (#4172 )

2022-02-22 19:39:24 -08:00

test_dbt_source.py

feat(ingest): dbt - add support for dbt meta mapping (#3832 )

2022-01-05 16:32:05 -08:00

test_domain_urn.py

feat(ingest): add Urn python library for DataJob, DataFlow, Domain and Tag (#4618 )

2022-04-12 09:02:28 +02:00

test_druid_source.py

chore: fix lint and remove incorrect integration mark from unit tests (#4621 )

2022-04-08 17:18:48 +02:00

test_elasticsearch_source.py

fix(ingestion): ElasticSearch when no properties from elastic_mappings, gracefully continue (#4853 )

2022-05-11 09:07:18 -07:00

test_file_lineage_source.py

feat(ingest): lineage-file - add ability to provide lineage manually through a file (#4116 )

2022-02-24 17:02:38 -08:00

test_glue_source_stubs.py

feat(ingestion): glue/s3 - Ingest Tags from s3 bucket on an AWS Glue job and S3 Data Lake Ingest Job (#4689 )

2022-04-29 10:09:06 +02:00

test_glue_source.py

feat(ingestion): glue/s3 - Ingest Tags from s3 bucket on an AWS Glue job and S3 Data Lake Ingest Job (#4689 )

2022-04-29 10:09:06 +02:00

test_great_expectations_action.py

feat(assertions): Adding Assertions Entity & Great Expectations BETA (#4305 )

2022-03-04 11:51:31 -08:00

test_hana_source.py

fix(build): fix for hana build failure for aarch64. (#5019 )

2022-05-26 15:29:21 -07:00

test_hive_source.py

chore: fix lint and remove incorrect integration mark from unit tests (#4621 )

2022-04-08 17:18:48 +02:00

test_iceberg.py

fix(iceberg): Change how MapType are mapped to Avro to support complex Map key type. (#5060 )

2022-06-09 08:13:10 +05:30

test_kafka_emitter.py

feat(ingest): add kafka emitters for MetadataChangeProposal format (#3018 )

2021-08-03 11:17:16 -07:00

test_kafka_sink.py

feat(ingest): add kafka emitters for MetadataChangeProposal format (#3018 )

2021-08-03 11:17:16 -07:00

test_kafka_source.py

feat(ingestion): optionally disable some kafka schema warnings (#4169 )

2022-05-24 14:27:02 -07:00

test_ldap_source.py

chore: fix lint and remove incorrect integration mark from unit tests (#4621 )

2022-04-08 17:18:48 +02:00

test_mapping.py

feat(ingest): dbt - improving dbt_meta mapping (#5237 )

2022-06-24 13:43:12 +02:00

test_mariadb_source.py

feat(ingest): add mariadb as possible source (#3245 )

2021-10-12 23:27:47 -07:00

test_mce_builder.py

Revert "fix(ingest): Use lower-case dataset names in the dataset urns for all SQL-styled datasets. (#4140 )" (#4218 )

2022-02-22 16:21:40 -08:00

test_mce_helpers.py

feat(ingest): refactor mce comparison and add pytest update golden files option (#2812 )

2021-06-30 16:53:20 -07:00

test_mcp_builder.py

fix(ingestion) containers: Adding platform instance to container keys (#4279 )

2022-03-16 14:57:50 -07:00

test_nifi_source.py

feat(ingest): nifi - handle provenance api variation for older versions (#4022 )

2022-02-01 10:03:05 -08:00

test_notebook_urn.py

feat(ingest): add python utility classes for NotebookUrn, CorpuserUrn and CorpGroupUrn (#4469 )

2022-03-23 16:07:57 -07:00

test_openapi.py

fix(ingest): handle endpoints without 200 response in openapi (#4332 )

2022-03-14 17:52:08 -07:00

test_oracle_source.py

fix(ingest): patch lookml types and refactor ingestion sources layout (#2950 )

2021-07-26 13:06:52 -07:00

test_packaging.py

test(ingestion): fix flaky package discovery test (#2949 )

2021-07-25 21:15:22 -07:00

test_parsing_util.py

feat(ingestion): snowflake, bigquery - enhancements to log and bugfix (#4442 )

2022-03-21 09:50:36 -07:00

test_pipeline.py

fix(cli): correct handling of env variables (#5203 )

2022-06-20 20:53:47 +05:30

test_plugin_system.py

feat(ingest): Adding Tableau Source Connector [BETA] (#4063 )

2022-02-08 14:26:44 -08:00

test_postgres_source.py

fix(ingest): patch lookml types and refactor ingestion sources layout (#2950 )

2021-07-26 13:06:52 -07:00

test_protobuf_util.py

feat(ingestion): kafka - add protobuf schema support (#4819 )

2022-05-04 17:07:01 -07:00

test_pulsar_source.py

feat(ingestion): add Pulsar source (#4721 )

2022-04-29 15:57:02 +05:30

test_redash_source.py

Revert "fix(ingest): Use lower-case dataset names in the dataset urns for all SQL-styled datasets. (#4140 )" (#4218 )

2022-02-22 16:21:40 -08:00

test_rest_emitter.py

feat(ingest): datahub-rest - Make datahub-rest client more robust by configurable retries. (#3826 ) (#3860 )

2022-01-11 19:35:06 -08:00

test_rest_sink.py

Introducing TimeSeries Aspects + Dataset Profile (Stats) Aspect (#2983 )

2021-07-30 17:41:03 -07:00

test_sagemaker_source_stubs.py

feat(ingest): type stubs for boto3 (#2975 )

2021-07-28 20:35:35 -07:00

test_schema_util.py

fix(ingest): common - fix nullability determination for the AVRO fixed type. (#5023 )

2022-05-29 09:06:08 -07:00

test_snowflake_source.py

feat(ingest): snowflake using oauth for Azure (#4647 )

2022-06-06 17:49:49 +05:30

test_source.py

test(ingestion): change class names to avoid unittest warnings (#5005 )

2022-05-26 22:09:40 +05:30

test_sql_common.py

test(ingestion): change class names to avoid unittest warnings (#5005 )

2022-05-26 22:09:40 +05:30

test_tag_urn.py

feat(ingest): add Urn python library for DataJob, DataFlow, Domain and Tag (#4618 )

2022-04-12 09:02:28 +02:00

test_transform_dataset.py

test(ingestion): change class names to avoid unittest warnings (#5005 )

2022-05-26 22:09:40 +05:30

test_urn.py

feat(ingest): add Urn python library for DataJob, DataFlow, Domain and Tag (#4618 )

2022-04-12 09:02:28 +02:00

test_usage_common.py

feat(ingestion): For all usage connectors, allow exclusion of top_n_queries from ingestion via a config param. (#4839 )

2022-05-12 14:26:03 -07:00

test_utilities.py

fix(bigquery): improve handling of extracted audit log sql queries (#4735 )

2022-05-03 14:43:23 +05:30

test_vertica_source.py

feat(ingest): Add Source from Vertica (#4555 )

2022-05-26 03:26:28 -07:00