diff --git a/src/spiffworkflow_backend/__init__.py b/src/spiffworkflow_backend/__init__.py index 058f20ad..9437a6ae 100644 --- a/src/spiffworkflow_backend/__init__.py +++ b/src/spiffworkflow_backend/__init__.py @@ -2,11 +2,10 @@ import os from typing import Any -import sqlalchemy - import connexion # type: ignore import flask.app import flask.json +import sqlalchemy from apscheduler.schedulers.background import BackgroundScheduler # type: ignore from flask_bpmn.api.api_error import api_error_blueprint from flask_bpmn.models.db import db @@ -31,15 +30,15 @@ class MyJSONEncoder(flask.json.JSONEncoder): """Default.""" if hasattr(obj, "serialized"): return obj.serialized - elif isinstance(obj, sqlalchemy.engine.row.Row): + elif isinstance(obj, sqlalchemy.engine.row.Row): # type: ignore return_dict = {} for row_key in obj.keys(): row_value = obj[row_key] - if (hasattr(row_value, '__dict__')): + if hasattr(row_value, "__dict__"): return_dict.update(row_value.__dict__) else: - return_dict.update({ row_key: row_value }) - return_dict.pop('_sa_instance_state') + return_dict.update({row_key: row_value}) + return_dict.pop("_sa_instance_state") return return_dict return super().default(obj) @@ -55,7 +54,7 @@ def start_scheduler(app: flask.app.Flask) -> None: scheduler.add_job( BackgroundProcessingService(app).run, "interval", - seconds=30, + seconds=5, ) scheduler.start() diff --git a/src/spiffworkflow_backend/services/logging_service.py b/src/spiffworkflow_backend/services/logging_service.py index caef3b0d..93c5ed6b 100644 --- a/src/spiffworkflow_backend/services/logging_service.py +++ b/src/spiffworkflow_backend/services/logging_service.py @@ -176,7 +176,7 @@ class DBHandler(logging.Handler): bpmn_process_identifier = record.workflow # type: ignore spiff_task_guid = str(record.task_id) # type: ignore bpmn_task_identifier = str(record.task_spec) # type: ignore - bpmn_task_type = record.task_type if hasattr(record, 'task_type') else None # type: ignore + bpmn_task_type = record.task_type if hasattr(record, "task_type") else None # type: ignore timestamp = record.created message = record.msg if hasattr(record, "msg") else None current_user_id = record.current_user_id if hasattr(record, "current_user_id") else None # type: ignore