Refactor pipeline and trigger API output to add Flowpipe metadata in its body.

[vhadianto]

Pipeline output:

{
    "output": {
        "val": "john",
        "val_2": "victor"
    },
    "flowpipe": {
        "execution_id": "exec_cqgfdb4204vt049ovip0",
        "pipeline": "test_mod.pipeline.report_pipeline",
        "pipeline_execution_id": "pexec_cqgfdb4204vt049ovipg",
        "params": {
            "param_1": "john",
            "param_2": "victor"
        }
    }
}

Trigger output:

{
    "results": [
        {
            "output": {
                "val": "john",
                "val_2": "victor"
            },
            "flowpipe": {
                "capture": "insert",
                "execution_id": "exec_cqgfdb4204vt049ovip0",
                "pipeline": "test_mod.pipeline.report_pipeline",
                "pipeline_execution_id": "pexec_cqgfdb4204vt049ovipg",
                "params": {
                    "param_1": "john",
                    "param_2": "victor"
                }
            }
        },
        {
            "output": {
                "val": "john",
            },
            "flowpipe": {
                "capture": "update",
                "execution_id": "exec_cqgfdb4204vt049ovip0",
                "pipeline": "test_mod.pipeline.report_pipeline",
                "pipeline_execution_id": "pexec_cqgfdb4204vt049ovipg",
                "params": {
                    "param_1": "john",
                    "param_2": "victor"
                }
            }
        }
    ],
    "flowpipe": {
        "trigger_type": "query",
        "process_id": "pl_123"
    }
}

[github-actions[bot]]

This issue is stale because it has been open 60 days with no activity. Remove stale label or comment or this will be closed in 30 days.