@@ -24,11 +24,13 @@ public function index() {
2424 ->orderBy ('updated_at ' )
2525 ->first ();
2626
27- if (config ('database.default ' ) === 'mongodb ' && $ maxWaitTimeWorkflow && $ maxWaitTimeWorkflow ->_id ) {
27+ $ dbDriverName = DB ::connection ()->getDriverName ();
28+
29+ if ($ dbDriverName === 'mongodb ' && $ maxWaitTimeWorkflow && $ maxWaitTimeWorkflow ->_id ) {
2830 $ maxWaitTimeWorkflow ->id = $ maxWaitTimeWorkflow ->_id ;
2931 }
3032
31- if (config ( ' database.default ' ) === 'mongodb ' ) {
33+ if ($ dbDriverName === 'mongodb ' ) {
3234 $ maxDurationWorkflow = config ('workflows.stored_workflow_model ' , StoredWorkflow::class)::select ('* ' )
3335 ->raw (function ($ collection ) {
3436 return $ collection ->aggregate ([
@@ -59,18 +61,18 @@ public function index() {
5961 $ maxDurationWorkflow ->id = $ maxDurationWorkflow ->_id ;
6062 } else {
6163 $ maxDurationWorkflow = config ('workflows.stored_workflow_model ' , StoredWorkflow::class)::select ('* ' )
62- ->when (config ( ' database.default ' ) === 'mysql ' , function ($ q ) {
64+ ->when ($ dbDriverName === 'mysql ' , function ($ q ) {
6365 return $ q ->addSelect (DB ::raw ('TIMEDIFF(created_at, updated_at) as duration ' ));
6466 })
65- ->when (config ( ' database.default ' ) === 'pgsql ' , function ($ q ) {
67+ ->when ($ dbDriverName === 'pgsql ' , function ($ q ) {
6668 return $ q ->addSelect (DB ::raw ('(EXTRACT(EPOCH FROM created_at - updated_at)) as duration ' ));
6769 })
6870 ->where ('status ' , '!= ' , 'pending ' )
6971 ->orderBy ('duration ' )
7072 ->first ();
7173 }
7274
73- if (config ( ' database.default ' ) === 'mongodb ' ) {
75+ if ($ dbDriverName === 'mongodb ' ) {
7476 $ maxExceptionsWorkflow = null ;
7577
7678 $ mostExceptionWorkflowId = StoredWorkflowException::raw (function ($ collection ) {
0 commit comments