bf2343b7e4
Integration Tests - MySQL + Elasticsearch / Detect Changes (push) Has been cancelled
Integration Tests - MySQL + Elasticsearch / integration-tests-mysql-elasticsearch (push) Has been cancelled
Integration Tests - PostgreSQL + Elasticsearch + Redis / Detect Changes (push) Has been cancelled
Integration Tests - PostgreSQL + Elasticsearch + Redis / integration-tests-postgres-elasticsearch-redis (push) Has been cancelled
Integration Tests - PostgreSQL + OpenSearch / Detect Changes (push) Has been cancelled
Integration Tests - PostgreSQL + OpenSearch / integration-tests-postgres-opensearch (push) Has been cancelled
Java Checkstyle / java-checkstyle (push) Has been cancelled
Maven Collate Tests / maven-collate-ci (push) Has been cancelled
OpenMetadata Service Unit Tests / openmetadata-service-unit-tests-status (push) Has been cancelled
Publish Package to Maven Central Repository / publish-maven-packages (push) Has been cancelled
OpenMetadata Service Unit Tests / Detect Changes (push) Has been cancelled
OpenMetadata Service Unit Tests / openmetadata-service-unit-tests (push) Has been cancelled
OpenMetadata Service Unit Tests / k8s_operator-unit-tests (push) Has been cancelled
154 lines
5.0 KiB
Markdown
154 lines
5.0 KiB
Markdown
# Code Style Standards
|
|
|
|
## Python
|
|
|
|
### Imports
|
|
Order: stdlib → third-party → OpenMetadata generated → OpenMetadata internal
|
|
|
|
```python
|
|
import json
|
|
import traceback
|
|
from functools import partial
|
|
from typing import Iterable, Optional
|
|
|
|
import requests
|
|
from sqlalchemy.engine import Engine
|
|
|
|
from metadata.generated.schema.entity.services.connections.database.myDbConnection import (
|
|
MyDbConnection,
|
|
)
|
|
from metadata.ingestion.api.models import Either
|
|
from metadata.ingestion.connections.connection import BaseConnection
|
|
from metadata.utils.logger import ingestion_logger
|
|
```
|
|
|
|
### Naming
|
|
- Connector directory: `snake_case` (e.g., `my_database`)
|
|
- Python classes: `PascalCase` (e.g., `MyDatabaseSource`)
|
|
- JSON Schema file: `lowerCamelCase` + `Connection.json` (e.g., `myDatabaseConnection.json`)
|
|
- Type enum: `PascalCase` (e.g., `MyDatabase`)
|
|
|
|
### Type Annotations
|
|
- All function signatures must have type annotations
|
|
- Use `Optional[T]` for nullable fields
|
|
- Use `Iterable[Either[...]]` for yield methods
|
|
- Import types from `typing` or `collections.abc`
|
|
|
|
### No Unnecessary Comments
|
|
- Do NOT add comments that describe what code obviously does
|
|
- Only comment complex business logic, non-obvious algorithms, or workarounds
|
|
- No Google-style docstrings with `Args:` / `Returns:` on simple methods
|
|
- If code needs a comment to be understood, refactor the code instead
|
|
|
|
### Pydantic Models
|
|
|
|
When defining Pydantic models for API responses with aliased fields:
|
|
- Always set `model_config = ConfigDict(populate_by_name=True)` when using `Field(alias=...)` — without it, constructing instances with Python attribute names raises `ValidationError`
|
|
- Use `Optional[T]` with `Field(None, alias=...)` for nullable fields
|
|
- Create list response wrapper models inheriting from a base OData/pagination response
|
|
|
|
```python
|
|
from pydantic import BaseModel, ConfigDict, Field
|
|
|
|
class MyApiReport(BaseModel):
|
|
model_config = ConfigDict(populate_by_name=True)
|
|
|
|
id: str = Field(alias="Id")
|
|
name: str = Field(alias="Name")
|
|
description: Optional[str] = Field(None, alias="Description")
|
|
|
|
|
|
class MyApiListResponse(BaseModel):
|
|
value: List[MyApiReport] = Field(default_factory=list)
|
|
```
|
|
|
|
### Error Messages
|
|
Include context in error messages:
|
|
|
|
```python
|
|
# Good
|
|
raise ValueError(f"Cannot connect to {config.hostPort}: {exc}")
|
|
|
|
# Bad
|
|
raise ValueError("Connection failed")
|
|
```
|
|
|
|
## JSON Schema
|
|
|
|
### File Naming
|
|
Schema file names use `lowerCamelCase`:
|
|
- `myDatabaseConnection.json` (not `my_database_connection.json`)
|
|
- `bigQueryConnection.json` (not `big_query_connection.json`)
|
|
|
|
### Required Fields
|
|
Every connection schema must have:
|
|
- `$id` with full URI path
|
|
- `$schema`: `http://json-schema.org/draft-07/schema#`
|
|
- `title`: PascalCase connection name
|
|
- `javaType`: Full Java class path
|
|
- `type`: `"object"`
|
|
- `definitions` block with type enum
|
|
- `additionalProperties: false`
|
|
|
|
### Property Conventions
|
|
- Use `title` for UI labels
|
|
- Use `description` for help text
|
|
- Use `format: "password"` for secrets
|
|
- Use `format: "uri"` for URLs
|
|
- Use `default` values where sensible
|
|
- Use `$ref` to compose from shared schemas
|
|
|
|
### $ref Paths
|
|
Paths are relative from the schema file location:
|
|
- Auth: `./common/basicAuth.json`
|
|
- SSL: `../../../../security/ssl/verifySSLConfig.json#/definitions/sslConfig`
|
|
- Filters: `../../../../type/filterPattern.json#/definitions/filterPattern`
|
|
- Connection extras: `../connectionBasicType.json#/definitions/connectionOptions`
|
|
- Capability flags: `../connectionBasicType.json#/definitions/supportsMetadataExtraction`
|
|
|
|
## Copyright Header
|
|
|
|
All Python files must start with:
|
|
|
|
```python
|
|
# Copyright 2025 OpenMetadata
|
|
# Licensed under the Collate Community License, Version 1.0 (the "License");
|
|
# you may not use this file except in compliance with the License.
|
|
# You may obtain a copy of the License at
|
|
# https://github.com/open-metadata/OpenMetadata/blob/main/ingestion/LICENSE
|
|
# Unless required by applicable law or agreed to in writing, software
|
|
# distributed under the License is distributed on an "AS IS" BASIS,
|
|
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
# See the License for the specific language governing permissions and
|
|
# limitations under the License.
|
|
```
|
|
|
|
## Formatting
|
|
|
|
- Python: `ruff` (lint + format, run `make py_format` to apply, `make py_format_check` to verify)
|
|
- Java: `spotless` (run `mvn spotless:apply`)
|
|
- Line length: 120
|
|
|
|
**Always run formatting before committing**:
|
|
```bash
|
|
source env/bin/activate
|
|
make py_format
|
|
mvn spotless:apply
|
|
```
|
|
|
|
If `make py_format` fails because tools are not installed:
|
|
```bash
|
|
source env/bin/activate
|
|
make install_dev generate
|
|
make py_format
|
|
```
|
|
|
|
## Pre-Merge Cleanup
|
|
|
|
`CONNECTOR_CONTEXT.md` is gitignored and stays local — no action needed for that file.
|
|
|
|
Before submitting a PR, verify:
|
|
- No scaffolding artifacts are staged (check `git status` — CONNECTOR_CONTEXT.md should not appear)
|
|
- Remove any `TODO` comments that are implementation instructions (keep only genuine future-work TODOs with ticket references)
|
|
- Remove any temporary test fixtures or mock data files that aren't part of the test suite
|