mirror of
https://github.com/windmill-labs/windmill.git
synced 2026-09-09 00:04:10 +00:00
chore: remove legacy wmill_pg python client (#8155)
The wmill_pg package (psycopg2 wrapper for running PostgreSQL queries) has been fully replaced by Windmill's native PostgreSQL support. Remove the package directory and all references from build, publish, install, version, LSP, and dependabot configs. Co-authored-by: Claude Opus 4.6 <noreply@anthropic.com>
This commit is contained in:
co-authored by
Claude Opus 4.6
parent
36353359f6
commit
6eca08480a
@@ -1,17 +0,0 @@
|
||||
# wmill
|
||||
|
||||
The postgres extension client for the [Windmill](https://windmill.dev) platform.
|
||||
|
||||
[windmill-api](https://pypi.org/project/windmill-api/).
|
||||
|
||||
## Quickstart
|
||||
|
||||
```python
|
||||
import wmill_pg
|
||||
|
||||
|
||||
def main():
|
||||
my_list = query("UPDATE demo SET value = 'value' RETURNING key, value")
|
||||
for key, value in my_list:
|
||||
...
|
||||
```
|
||||
Binary file not shown.
Binary file not shown.
@@ -1,48 +0,0 @@
|
||||
[tool.poetry]
|
||||
name = "wmill-pg"
|
||||
version = "1.647.0"
|
||||
description = "An extension client for the wmill client library focused on pg"
|
||||
license = "Apache-2.0"
|
||||
homepage = "https://windmill.dev"
|
||||
documentation = "https://windmill.dev"
|
||||
|
||||
authors = ["Ruben Fiszel <ruben@windmill.dev>"]
|
||||
|
||||
readme = "README.md"
|
||||
packages = [
|
||||
{include = "wmill_pg"},
|
||||
]
|
||||
include = ["wmill_pg/py.typed"]
|
||||
|
||||
[tool.poetry.dependencies]
|
||||
python = "^3.7"
|
||||
wmill = "^1.5.0"
|
||||
psycopg2-binary = "*"
|
||||
|
||||
[build-system]
|
||||
requires = ["poetry>=1.0.2", "poetry-dynamic-versioning"]
|
||||
build-backend = "poetry.masonry.api"
|
||||
|
||||
[tool.poetry-dynamic-versioning]
|
||||
enable = true
|
||||
vcs = "git"
|
||||
style = "semver"
|
||||
format-jinja = "{% if distance == 0 %}{{ base }}{% else %}{{ base }}+{{ distance }}.{{ commit }}{% endif %}"
|
||||
|
||||
|
||||
[tool.black]
|
||||
line-length = 120
|
||||
target_version = ['py36', 'py37', 'py38']
|
||||
exclude = '''
|
||||
(
|
||||
/(
|
||||
| \.git
|
||||
| \.venv
|
||||
| \.mypy_cache
|
||||
)/
|
||||
)
|
||||
'''
|
||||
|
||||
[tool.isort]
|
||||
line_length = 120
|
||||
profile = "black"
|
||||
@@ -1 +0,0 @@
|
||||
from .client import *
|
||||
@@ -1,40 +0,0 @@
|
||||
from typing import Any
|
||||
|
||||
import wmill
|
||||
|
||||
import psycopg2
|
||||
|
||||
|
||||
def query(query: str, connection: "str | dict[str, Any]" = "g/all/postgres") -> "list[tuple[Any, ...]] | None":
|
||||
"""
|
||||
Query a postgres database using psycopg2 library underneath. See its documentation for more info.
|
||||
|
||||
Args:
|
||||
query: The query as string, without ending ';'
|
||||
resource: The path of the resource of type 'postgres' containing the connection info.
|
||||
The default value is 'g/all/postgres'. It is by convention the default postgres
|
||||
db of any given workspace.
|
||||
|
||||
Return:
|
||||
Either None if it is a non returning statement or a list of tuple for statement with return values.
|
||||
"""
|
||||
if isinstance(connection, str):
|
||||
pg_con = wmill.get_resource(connection)
|
||||
if pg_con is None:
|
||||
raise Exception(f"Resource {connection} not found")
|
||||
else:
|
||||
pg_con = connection
|
||||
|
||||
|
||||
conn = psycopg2.connect(**pg_con)
|
||||
cur = conn.cursor()
|
||||
cur.execute(f"{query};")
|
||||
if cur.description:
|
||||
res = cur.fetchall()
|
||||
else:
|
||||
res = None
|
||||
conn.commit()
|
||||
cur.close()
|
||||
conn.close()
|
||||
return res
|
||||
|
||||
@@ -1 +0,0 @@
|
||||
# Marker file for PEP 561
|
||||
Reference in New Issue
Block a user