File tree
2,083 files changed
+2103
-2095
lines changed- .github
- ISSUE_TEMPLATE
- workflows
- cicd
- examples
- airflow-example
- airflow-transform-job
- airflow-trino-job1
- airflow-trino-job2
- dags
- chunker
- confluence-data-retrieval-example
- confluence-reader
- dag-example
- example-dag
- ingest-job1
- ingest-job2
- read-data-job
- dag-with-args-example
- dag-job
- ingest-job-table-one
- ingest-job-table-two
- read-job-canada
- read-job-rest-of-world
- read-job-usa
- energy
- energy
- gdp-execution-id-example
- incremental-ingest-from-db-example
- ingest-and-anonymize-plugin
- jobs/ingest-currency-exchange-rate
- plugins/vdk-poc-anonymize
- src/vdk/plugin/anonymize
- tests
- jobs/ingest-job
- ingest-from-db-example/ingest-from-db-example-job
- ingest-from-rest-api-example/ingest-from-rest-api-example-job
- ingest-from-s3-example/ingest-from-s3-example-job
- life-expectancy
- life-expectancy
- online-exhibition
- online-exhibition
- pgvector-embedder
- common
- rag-chat-api
- rag-dag-pipeline
- supported-python-versions-example
- control-service-setup
- multiple-python-version-usage/test-job
- projects
- control-service
- cicd
- projects
- base/src
- main/java/com/vmware/taurus
- base
- exception
- security
- service/diag
- methodintercept
- opid
- telemetry
- test/java/com/vmware/taurus
- exception
- service/diag/telemetry
- helm_charts
- airflow
- pipelines-control-service
- templates
- frontend
- job-base-image-secure
- job-base-image
- job-builder-rootless
- job-builder-secure
- job-builder
- model
- apidefs/datajob-api
- openapi-code-generator
- pipelines_control_service/src
- integration-test
- java/com/vmware/taurus
- datajobs/it
- common
- graphql/it
- secrets/service/vault
- service/deploy
- resources
- data_job_templates
- main
- java/com/vmware/taurus
- authorization
- config
- provider
- webhook
- datajobs
- webhook
- exception
- properties
- controller
- service
- secrets
- controller
- service
- vault
- service
- credentials
- webhook
- deploy
- execution
- graphql
- model
- strategy
- datajob
- kubernetes
- locks
- model
- converter
- monitoring
- notification
- repository
- threads
- upload
- webhook
- resources
- test
- java/com/vmware/taurus
- authorization
- provider
- webhook
- datajobs
- webhook
- properties
- secrets
- vault
- service
- credentials
- deploy
- execution
- graphql
- strategy
- datajob
- model
- converter
- monitoring
- notification
- repository
- upload
- resources
- detect-job
- package
- subpackage
- filter-job
- frontend
- cicd
- data-pipelines/gui
- e2e
- integration
- frontend-tests
- explore/data-jobs
- details
- executions
- get-started
- manage/data-jobs
- details
- executions
- router
- quickstart-operability
- plugins
- helpers
- support
- helpers
- pages
- base
- data-pipelines
- explore/data-jobs
- details
- executions
- get-started
- manage/data-jobs
- details
- executions
- projects
- data-pipelines
- src
- lib
- commons
- filters-manager
- components
- base-grid
- data-jobs-explore
- components/grid
- data-jobs-manage
- components/grid
- data-job
- pages
- details
- executions
- data-job-deployment-details-modal
- data-job-execution-status-filter
- data-job-execution-status
- data-job-execution-type-filter
- data-job-execution-type
- data-job-executions-grid
- comparators
- date
- default
- duration
- criteria
- status
- string
- type
- data-job-executions-page
- criteria/time-period
- execution-duration-chart
- execution-status-chart
- model
- time-period-filter
- widgets
- data-jobs-executions-widget
- data-jobs-failed-widget
- data-jobs-health-panel
- widget-execution-status-gauge
- model
- services
- state
- actions
- effects
- error-codes
- tasks
- ui
- src
- app
- getting-started
- assets/css
- environments
- vdk-control-cli
- cicd
- src/vdk
- api/control/plugin
- internal/control
- command_groups
- common_group
- info_group
- job
- login_group
- logout_group
- version_group
- configuration
- exception
- job
- sample_job
- plugin
- rest_lib
- utils
- tests
- resources
- sample_job_module
- vdk/internal
- control
- command_groups
- common_group
- info_group
- job
- login_group
- configuration
- plugin
- utils
- vdk-core
- cicd
- example-job
- src
- vdk
- api
- plugin
- internal
- builtin_plugins
- config
- connection
- impl
- pep249
- debug
- ingestion
- job_properties
- job_secrets
- notification
- run
- templates
- termination_message
- version
- core
- plugin
- util
- tests
- functional
- cli
- ingestion
- jobs
- ingest-job
- ingest-multiple-threads-job
- no-ingest-method-job
- test-ingest-bad-payload-job
- test-ingest-job
- test-ingest-multiple-methods-job
- run
- jobs
- cancel-job-template
- cancel-job
- different-source-and-ingest-target
- fail-job-indirect-library
- fail-job-ingest-iterator
- fail-job-properties
- fail-job-secrets
- fail-job
- ingest_to_two_dbs_with_different_types
- job-ingest-to-two-dbs-templates
- job-name-directory
- job-using-risky-templates
- job-using-templates
- job-using-two-different-dbs-templates
- job-with-args
- job-with-config-ini
- multiple-dbs-from-different-type-job
- multiple-dbs-from-same-type-python-job
- pandas-job
- pandas-key-error-job
- properties-job
- secrets-job
- simple-job-config-ini-sections
- simple-job-config-ini
- simple-job
- simple-query-failed-handled
- syntax-error-job
- template-append
- template-csv-risky
- template-ingest-to-two-dbs
- write-directory
- vdk/internal
- builtin_plugins
- config
- connection
- debug
- ingestion
- job_properties
- job_secrets
- notification
- run
- templates
- termination_message
- version
- core
- plugin
- vdk-heartbeat
- cicd
- src/vdk/internal/heartbeat
- vdk_heartbeat_data_job
- database_ingestion
- empty
- impala
- simple
- trino
- tests/vdk/internal
- vdk-plugins
- airflow-provider-vdk
- tests
- hooks
- operators
- sensors
- vdk_provider
- example_dags
- hooks
- operators
- sensors
- quickstart-vdk
- tests
- vdk-audit
- src/vdk/plugin/audit
- tests/functional
- jobs
- os-listdir-command-job
- os-remove-command-job
- os-system-command-job
- vdk-confluence-data-source
- src/vdk/plugin/confluence_data_source
- tests
- jobs/ingest-test-job
- vdk-control-api-auth
- src/vdk/plugin/control_api_auth
- tests
- vdk-csv
- src/vdk/plugin/csv
- csv_export_job
- csv_ingest_job
- tests/functional
- vdk-dag
- src/vdk/plugin/dag
- api
- tests
- jobs
- dag-all-status-check
- dag-arguments
- dag-circular-dep
- dag-depends-on-itself
- dag-duplicate-jobs
- dag-empty-arguments
- dag-exceed-limit
- dag-not-allowed-job-key
- dag-specified-status-checks
- dag-wrong-job-arguments-type
- dag-wrong-job-key-type
- dag-wrong-job-type
- dag-wrong-topological-order
- dag
- fail-job
- local-dag
- read-file-job
- write-file-job
- vdk-data-source-git
- src/vdk/plugin/data_source_git
- tests
- jobs/ingest-git-job
- vdk-data-sources
- src/vdk/plugin/data_sources
- mapping
- tests
- functional
- jobs
- ingest-data-flow-job
- ingest-data-flow-map-func-job
- ingest-data-flow-toml-job
- ingest-sources-job
- mapping
- vdk-duckdb
- src/vdk/plugin/duckdb
- tests
- jobs/test-duckdb-job
- vdk-gdp-execution-id
- src/vdk/plugin/gdp/execution_id
- tests/functional
- jobs/sql-job
- vdk-greenplum
- src/vdk/plugin/greenplum
- tests
- jobs/test_ingest_to_greenplum_job
- vdk-huggingface
- src/vdk/plugin/huggingface
- tests
- jobs/huggingface-job
- vdk-impala
- src/vdk/plugin/impala
- templates
- load
- dimension
- scd1
- scd2
- fact
- insert
- snapshot
- versioned
- tests
- functional
- jobs
- insert_template_job
- insert_template_partition_job
- load_dimension_scd1_template_job
- load_dimension_scd1_template_only
- load_dimension_scd1_template_partition_job
- load_dimension_scd2_template_job
- load_dimension_scd2_template_only
- load_fact_snapshot_template_job_empty_source
- load_fact_snapshot_template_job
- load_fact_snapshot_template_only
- load_fact_snapshot_template_partition_job
- load_versioned_template_job
- load_versioned_template_only
- load_versioned_template_partition_job
- vdk-ingest-file
- src/vdk/plugin/ingest_file
- tests
- vdk-ingest-http
- src/vdk/plugin/ingest_http
- tests
- functional
- jobs/ingest-job
- vdk-ipython
- src/vdk/plugin/ipython
- tests
- vdk-jobs-troubleshooting
- src/vdk/plugin/jobs_troubleshoot
- api
- troubleshoot_utilities
- tests
- functional
- jobs/request-thread-dump
- vdk-jupyter
- cicd
- vdk-jupyterlab-extension
- src
- __tests__
- components
- vdkOptions
- style
- testutils
- ui-tests
- tests
- data/convert-test-job-dirty
- vdk_jupyterlab_extension
- tests
- vdk_options
- vdk-kerberos-auth
- src/vdk/plugin/kerberos
- api
- tests
- jobs/test-job
- vdk-lineage-model
- src/vdk/api/lineage/model
- logger
- sql
- tests
- vdk-lineage
- src/vdk/plugin
- lineage
- marquez
- docker
- tests
- vdk-logging-format
- src/vdk/plugin/logging_format
- tests
- vdk-notebook
- src/vdk/plugin/notebook
- tests
- jobs/mixed-job
- vdk-oauth-auth
- vdk-oracle
- src/vdk/plugin/oracle
- tests
- jobs
- oracle-ingest-data-frame-schema-inference
- oracle-ingest-job-blob
- oracle-ingest-job-case-insensitive
- oracle-ingest-job-different-payloads-no-table-special-chars
- oracle-ingest-job-different-payloads-no-table
- oracle-ingest-job-different-payloads
- oracle-ingest-job-mixed-case-error
- oracle-ingest-job-mixed-case-no-inference
- oracle-ingest-job-no-table-special-chars
- oracle-ingest-job-no-table
- oracle-ingest-job-special-chars
- oracle-ingest-job-type-inference
- oracle-ingest-job
- oracle-ingest-nan-job
- oracle-ingest-two-db-conn-job
- vdk-plugin-control-cli
- src/vdk/plugin/control_cli_plugin
- tests
- jobs
- properties-job
- secrets-job
- simple-job
- vdk-postgres
- src/vdk/plugin/postgres
- tests
- jobs
- test-ingest
- test-multiple-db
- vdk-properties-fs
- src/vdk/plugin/properties_fs
- tests
- jobs
- write-read-properties-job-1
- write-read-properties-job
- vdk-server
- src/vdk/plugin/server
- tests
- vdk-singer
- src/vdk/plugin/singer
- tests
- jobs
- ingest-singer-tap-api-job
- ingest-singer-tap-job
- vdk-smarter
- src/vdk/plugin/smarter
- tests
- vdk-snowflake
- src/vdk/plugin/snowflake
- tests
- vdk-sqlite
- src/vdk/plugin/sqlite
- tests
- jobs/python-job-multiple
- vdk-storage
- src/vdk/plugin/storage
- tests
- jobs/job-using-a-plugin
- vdk-structlog
- src/vdk/plugin/structlog
- tests
- jobs/job-with-bound-logger
- vdk-test-utils
- src/vdk/plugin/test_utils
- tests
- vdk-trino
- src/vdk/plugin/trino
- templates/load
- dimension
- scd1_upsert
- scd1
- fact
- insert
- snapshot
- versioned
- tests
- jobs
- insert_template_job
- load_dimension_scd1_template_job
- load_dimension_scd1_upsert_template_job
- load_fact_periodic_snapshot_template_job_empty_source
- load_fact_periodic_snapshot_template_job
- load_versioned_scd2_template_job
- test_ingest_to_trino_job
- test_ingest_to_trino_multiple_db
- test_move_data_strategy_job
- specs/vep-2448-vdk-run-logs-simplified-and-readable
- support/gitlab-runners
Some content is hidden
Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.
2,083 files changed
+2103
-2095
lines changed| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
1 | | - | |
| 1 | + | |
2 | 2 | | |
3 | 3 | | |
4 | 4 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
1 | | - | |
| 1 | + | |
2 | 2 | | |
3 | 3 | | |
4 | 4 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
1 | | - | |
| 1 | + | |
2 | 2 | | |
3 | 3 | | |
4 | 4 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
1 | | - | |
| 1 | + | |
2 | 2 | | |
3 | 3 | | |
4 | 4 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
1 | | - | |
| 1 | + | |
2 | 2 | | |
3 | 3 | | |
4 | 4 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
1 | | - | |
| 1 | + | |
2 | 2 | | |
3 | 3 | | |
4 | 4 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
1 | | - | |
| 1 | + | |
2 | 2 | | |
3 | 3 | | |
4 | 4 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
1 | | - | |
| 1 | + | |
2 | 2 | | |
3 | 3 | | |
4 | 4 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
1 | | - | |
| 1 | + | |
2 | 2 | | |
3 | 3 | | |
4 | 4 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
1 | | - | |
| 1 | + | |
2 | 2 | | |
3 | 3 | | |
4 | 4 | | |
| |||
0 commit comments