Compatible with snakemake-interface-logger-plugins>=1.2.3

Author: jmzhang1911

.vscode/settings.json

@@ -1,5 +1,5 @@
 {
-    "python-envs.defaultEnvManager": "ms-python.python:conda",
-    "python-envs.defaultPackageManager": "ms-python.python:conda",
+    "python-envs.defaultEnvManager": "ms-python.python:venv",
+    "python-envs.defaultPackageManager": "ms-python.python:pip",
     "python-envs.pythonProjects": []
 }

README.md

@@ -4,6 +4,8 @@ A Snakemake logger plugin designed to be used with **[FlowO](https://github.com/
 
 **Demo page: [flowo online](https://zhanghaomiao.github.io/flowo)**
 
+**Important:** This plugin is designed to be used together with FlowO and requires FlowO to function correctly. It is not a standalone monitoring tool.
+
 ## 🎈 Features
 
 - Stores Snakemake workflow execution data in PostgreSQL database
@@ -32,10 +34,13 @@ The following environment variables are available for configuration in the `.env
 - `POSTGRES_PASSWORD`: PostgreSQL password (default: flowo_password)
 - `POSTGRES_DB`: PostgreSQL database name (default: flowo_logs)
 - `POSTGRES_HOST`: PostgreSQL host (default: localhost)
-- `POSTGRES_PORT`: PostgreSQL port (default: localhost: 5432)
+- `POSTGRES_PORT`: PostgreSQL port (default: 5432)
 - `FLOWO_USER`: User displayed in Flowo
 - `FLOWO_WORKING_PATH`: Snakemake execution project path
 
+**Note:** The PostgreSQL database used by this plugin is configured in FlowO. Ensure FlowO is properly set up before using this logger plugin.
+```
+
 ## 🚀 Usage
 Basic usage
 ```bash

pyproject.toml

@@ -4,7 +4,7 @@ build-backend = "hatchling.build"
 
 [project]
 name = "snakemake-logger-plugin-flowo"
-version = "0.1.8"
+version = "0.1.9"
 description = "A Snakemake logger plugin that stores workflow execution data in PostgreSQL"
 readme = "README.md"
 requires-python = ">=3.12"

snakemake_logger_plugin_flowo/__init__.py

@@ -51,5 +51,8 @@ def needs_rulegraph(self) -> bool:
         """Whether this plugin requires the DAG rulegraph."""
         return True
 
+    def emit(self, record):
+        return PostgresqlLogHandler.emit(self, record)
+
 
 __all__ = ["LogHandler"]

snakemake_logger_plugin_flowo/event_handlers.py

@@ -92,7 +92,7 @@ def handle(
         self, record: LogRecord, session: Session, context: Dict[str, Any]
     ) -> None:
         workflow_data = parsers.WorkflowStarted.from_record(record)
-
+        logger.info(f"Starting workflow with ID: {workflow_data.workflow_id}")
         workflow = Workflow(
             id=workflow_data.workflow_id,
             snakefile=workflow_data.snakefile,