tests package

Subpackages

• tests.platform package
  • Submodules
  • tests.platform.conftest module
    • is_master()
    • oidc_token_fixture()
    • pytest_configure()
    • pytest_configure_node()
  • tests.platform.helper module
    • HTTPStatus
      • HTTPStatus.ACCEPTED
      • HTTPStatus.ALREADY_REPORTED
      • HTTPStatus.BAD_GATEWAY
      • HTTPStatus.BAD_REQUEST
      • HTTPStatus.CONFLICT
      • HTTPStatus.CONTINUE
      • HTTPStatus.CREATED
      • HTTPStatus.EARLY_HINTS
      • HTTPStatus.EXPECTATION_FAILED
      • HTTPStatus.FAILED_DEPENDENCY
      • HTTPStatus.FORBIDDEN
      • HTTPStatus.FOUND
      • HTTPStatus.GATEWAY_TIMEOUT
      • HTTPStatus.GONE
      • HTTPStatus.HTTP_VERSION_NOT_SUPPORTED
      • HTTPStatus.IM_A_TEAPOT
      • HTTPStatus.IM_USED
      • HTTPStatus.INSUFFICIENT_STORAGE
      • HTTPStatus.INTERNAL_SERVER_ERROR
      • HTTPStatus.LENGTH_REQUIRED
      • HTTPStatus.LOCKED
      • HTTPStatus.LOOP_DETECTED
      • HTTPStatus.METHOD_NOT_ALLOWED
      • HTTPStatus.MISDIRECTED_REQUEST
      • HTTPStatus.MOVED_PERMANENTLY
      • HTTPStatus.MULTIPLE_CHOICES
      • HTTPStatus.MULTI_STATUS
      • HTTPStatus.NETWORK_AUTHENTICATION_REQUIRED
      • HTTPStatus.NON_AUTHORITATIVE_INFORMATION
      • HTTPStatus.NOT_ACCEPTABLE
      • HTTPStatus.NOT_EXTENDED
      • HTTPStatus.NOT_FOUND
      • HTTPStatus.NOT_IMPLEMENTED
      • HTTPStatus.NOT_MODIFIED
      • HTTPStatus.NO_CONTENT
      • HTTPStatus.OK
      • HTTPStatus.PARTIAL_CONTENT
      • HTTPStatus.PAYMENT_REQUIRED
      • HTTPStatus.PERMANENT_REDIRECT
      • HTTPStatus.PRECONDITION_FAILED
      • HTTPStatus.PRECONDITION_REQUIRED
      • HTTPStatus.PROCESSING
      • HTTPStatus.PROXY_AUTHENTICATION_REQUIRED
      • HTTPStatus.REQUESTED_RANGE_NOT_SATISFIABLE
      • HTTPStatus.REQUEST_ENTITY_TOO_LARGE
      • HTTPStatus.REQUEST_HEADER_FIELDS_TOO_LARGE
      • HTTPStatus.REQUEST_TIMEOUT
      • HTTPStatus.REQUEST_URI_TOO_LONG
      • HTTPStatus.RESET_CONTENT
      • HTTPStatus.SEE_OTHER
      • HTTPStatus.SERVICE_UNAVAILABLE
      • HTTPStatus.SWITCHING_PROTOCOLS
      • HTTPStatus.TEMPORARY_REDIRECT
      • HTTPStatus.TOO_EARLY
      • HTTPStatus.TOO_MANY_REQUESTS
      • HTTPStatus.UNAUTHORIZED
      • HTTPStatus.UNAVAILABLE_FOR_LEGAL_REASONS
      • HTTPStatus.UNPROCESSABLE_ENTITY
      • HTTPStatus.UNSUPPORTED_MEDIA_TYPE
      • HTTPStatus.UPGRADE_REQUIRED
      • HTTPStatus.USE_PROXY
      • HTTPStatus.VARIANT_ALSO_NEGOTIATES
      • HTTPStatus.is_client_error
      • HTTPStatus.is_informational
      • HTTPStatus.is_redirection
      • HTTPStatus.is_server_error
      • HTTPStatus.is_success
    • connector_action()
    • delete()
    • extract_object_by_name()
    • gen_pipeline_name()
    • get()
    • http_request()
    • patch_json()
    • post_json()
    • put_json()
    • unique_pipeline_name()
    • wait_for_condition()
    • wait_for_program_success()
  • tests.platform.negative_test module
    • NegativeCompilationTests
      • NegativeCompilationTests.test_errors0()
      • NegativeCompilationTests.test_initialization_error()
      • NegativeCompilationTests.test_program_error0()
      • NegativeCompilationTests.test_program_error1()
      • NegativeCompilationTests.test_rust_error()
      • NegativeCompilationTests.test_sql_error()
  • tests.platform.test_checkpoint_suspend module
  • tests.platform.test_checkpoint_sync module
  • tests.platform.test_cluster_health module
    • test_cluster_health_check()
    • test_health_check()
  • tests.platform.test_completion_tokens module
    • test_completion_tokens()
    • test_completion_tokens_with_outputs()
  • tests.platform.test_ingress_formats module
    • JsonLineReader
      • JsonLineReader.read_events()
    • create_pipeline()
    • test_case_sensitive_tables()
    • test_duplicate_outputs()
    • test_json_ingress()
    • test_map_column()
    • test_parse_datetime()
    • test_primary_keys()
    • test_quoted_columns()
    • test_upsert()
  • tests.platform.test_metrics_logs module
    • test_pipeline_logs()
    • test_pipeline_metrics()
    • test_pipeline_stats()
  • tests.platform.test_oidc_auth_simple module
    • test_authenticated_endpoint_access()
    • test_authentication_config_discovery()
    • test_malformed_token_rejection()
    • test_obtain_access_token()
    • test_oidc_discovery_endpoint()
    • test_unauthenticated_request_rejection()
  • tests.platform.test_orchestration module
    • test_pipeline_orchestration_basic()
    • test_pipeline_orchestration_errors()
    • test_pipeline_orchestration_scenarios()
  • tests.platform.test_pipeline_builder module
    • TestPipelineBuilder
      • TestPipelineBuilder.test_connector_orchestration()
  • tests.platform.test_pipeline_configs module
    • test_pipeline_program_config()
    • test_pipeline_runtime_config()
  • tests.platform.test_pipeline_crud module
    • test_pipeline_connector_endpoint_naming()
    • test_pipeline_create_compile_delete()
    • test_pipeline_get()
    • test_pipeline_get_selector()
    • test_pipeline_name_conflict()
    • test_pipeline_name_invalid()
    • test_pipeline_post()
    • test_refresh_version()
  • tests.platform.test_pipeline_lifecycle module
  • tests.platform.test_shared_pipeline module
  • tests.platform.test_shared_pipeline_stress module
    • TestPipeline
      • TestPipeline.test_create_pipeline()
      • TestPipeline.test_get_pipeline_logs()
  • Module contents
• tests.runtime package
  • Submodules
  • tests.runtime.test_adhoc_queries module
    • TestAdhocQueries
      • TestAdhocQueries.pipeline
      • TestAdhocQueries.test_pipeline_adhoc_query()
      • TestAdhocQueries.test_pipeline_adhoc_query_empty()
  • tests.runtime.test_uda module
    • test_uda()
  • tests.runtime.test_udf module
    • TestUDF
      • TestUDF.test_local()
  • Module contents

Submodules

tests.conftest module

tests.conftest.fixture_pipeline_name(request)

tests.shared_test_pipeline module

class tests.shared_test_pipeline.SharedTestPipeline(methodName='runTest')

Bases: TestCase

new_pipeline_with_suffix(suffix: str) → Pipeline

property pipeline: Pipeline

setUp()

Hook method for setting up the test fixture before exercising it.

classmethod setUpClass()

Hook method for setting up class fixture before running tests in the class.

tearDown()

Hook method for deconstructing the test fixture after testing it.

tests.shared_test_pipeline.sql(text_or_iterable)

Decorator to attach SQL (string or list/tuple of strings) to a test method.

Module contents

tests.enterprise_only(fn)

tests.unique_pipeline_name(base_name: str) → str

In CI, multiple tests of different runs can run against the same Feldera instance, we make sure the pipeline names they use are unique by appending the first 5 characters of the commit SHA or ‘local’ if not in CI.