sartography
/
spiffworkflow-backend
mirror of https://github.com/sartography/spiffworkflow-backend.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Merge commit '4fdb0f3ec4b3b6a68cc2e56ed84ffb6dc2743068'

This commit is contained in:
burnettk 2022-10-19 19:32:59 -04:00
parent a961b2a188 af8dd9e2d6
commit 30d04282b1
4 changed files with 8 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
migrations/env.py
View File

@ -1,3 +1,5 @@
from __future__ import with_statement
import logging import logging
from logging.config import fileConfig from logging.config import fileConfig

8
migrations/versions/3a95e16cf17c_.py → migrations/versions/9e14b40371f3_.py
View File

@ -1,8 +1,8 @@
"""empty message """empty message
Revision ID: 3a95e16cf17c Revision ID: 9e14b40371f3
Revises: Revises:
Create Date: 2022-10-19 12:42:38.086243 Create Date: 2022-10-19 19:31:20.431800
""" """
from alembic import op from alembic import op
@ -10,7 +10,7 @@ import sqlalchemy as sa
# revision identifiers, used by Alembic. # revision identifiers, used by Alembic.
revision = '3a95e16cf17c' revision = '9e14b40371f3'
down_revision = None down_revision = None
branch_labels = None branch_labels = None
depends_on = None depends_on = None
@ -166,7 +166,7 @@ def upgrade():
sa.Column('task_type', sa.String(length=50), nullable=True), sa.Column('task_type', sa.String(length=50), nullable=True),
sa.Column('task_status', sa.String(length=50), nullable=True), sa.Column('task_status', sa.String(length=50), nullable=True),
sa.Column('process_model_display_name', sa.String(length=255), nullable=True), sa.Column('process_model_display_name', sa.String(length=255), nullable=True),
sa.Column('task_data', sa.Text(), nullable=True), sa.Column('task_data', sa.Text(length=4294000000), nullable=True),
sa.ForeignKeyConstraint(['assigned_principal_id'], ['principal.id'], ), sa.ForeignKeyConstraint(['assigned_principal_id'], ['principal.id'], ),
sa.ForeignKeyConstraint(['process_instance_id'], ['process_instance.id'], ), sa.ForeignKeyConstraint(['process_instance_id'], ['process_instance.id'], ),
sa.PrimaryKeyConstraint('id'), sa.PrimaryKeyConstraint('id'),

2
src/spiffworkflow_backend/models/active_task.py
View File

@ -46,7 +46,7 @@ class ActiveTaskModel(SpiffworkflowBaseDBModel):
task_type = db.Column(db.String(50)) task_type = db.Column(db.String(50))
task_status = db.Column(db.String(50)) task_status = db.Column(db.String(50))
process_model_display_name = db.Column(db.String(255)) process_model_display_name = db.Column(db.String(255))
task_data: str = db.Column(db.Text) task_data: str = db.Column(db.Text(4294000000))
@classmethod @classmethod
def to_task(cls, task: ActiveTaskModel) -> Task: def to_task(cls, task: ActiveTaskModel) -> Task:

2
src/spiffworkflow_backend/services/service_task_service.py
View File

@ -52,7 +52,7 @@ class ServiceTaskDelegate:
} }
params["spiff__task_data"] = json.dumps(task_data) params["spiff__task_data"] = json.dumps(task_data)
proxied_response = requests.get(f"{connector_proxy_url()}/v1/do/{name}", params) proxied_response = requests.post(f"{connector_proxy_url()}/v1/do/{name}", params)
if proxied_response.status_code != 200: if proxied_response.status_code != 200:
print("got error from connector proxy") print("got error from connector proxy")