@@ -54,7 +54,7 @@ public function create($name, array $params = [])
54
54
$ cronStatus = $ this ->serviceLocator ->get ('Magento\Setup\Model\Cron\Status ' );
55
55
$ statusStream = fopen ($ cronStatus ->getStatusFilePath (), 'a+ ' );
56
56
$ logStream = fopen ($ cronStatus ->getLogFilePath (), 'a+ ' );
57
- $ multipleStreamOutput = new MultipleStreamOutput ([$ statusStream , $ logStream ]);
57
+ $ streamOutput = new MultipleStreamOutput ([$ statusStream , $ logStream ]);
58
58
$ objectManagerProvider = $ this ->serviceLocator ->get ('Magento\Setup\Model\ObjectManagerProvider ' );
59
59
/** @var \Magento\Framework\ObjectManagerInterface $objectManager */
60
60
$ objectManager = $ objectManagerProvider ->get ();
@@ -63,7 +63,7 @@ public function create($name, array $params = [])
63
63
return new JobUpgrade (
64
64
$ this ->serviceLocator ->get ('Magento\Setup\Console\Command\UpgradeCommand ' ),
65
65
$ objectManagerProvider ,
66
- $ multipleStreamOutput ,
66
+ $ streamOutput ,
67
67
$ this ->serviceLocator ->get ('Magento\Setup\Model\Cron\Queue ' ),
68
68
$ cronStatus ,
69
69
$ name ,
@@ -73,7 +73,7 @@ public function create($name, array $params = [])
73
73
case self ::JOB_DB_ROLLBACK :
74
74
return new JobDbRollback (
75
75
$ objectManager ->get ('Magento\Framework\Setup\BackupRollbackFactory ' ),
76
- $ multipleStreamOutput ,
76
+ $ streamOutput ,
77
77
$ cronStatus ,
78
78
$ objectManagerProvider ,
79
79
$ name ,
@@ -83,7 +83,7 @@ public function create($name, array $params = [])
83
83
case self ::JOB_STATIC_REGENERATE :
84
84
return new JobStaticRegenerate (
85
85
$ objectManagerProvider ,
86
- $ multipleStreamOutput ,
86
+ $ streamOutput ,
87
87
$ cronStatus ,
88
88
$ name ,
89
89
$ params
@@ -104,7 +104,7 @@ public function create($name, array $params = [])
104
104
$ moduleUninstall ,
105
105
$ themeUninstall ,
106
106
$ objectManagerProvider ,
107
- $ multipleStreamOutput ,
107
+ $ streamOutput ,
108
108
$ this ->serviceLocator ->get ('Magento\Setup\Model\Cron\Queue ' ),
109
109
$ cronStatus ,
110
110
$ this ->serviceLocator ->get ('Magento\Setup\Model\Updater ' ),
@@ -116,7 +116,7 @@ public function create($name, array $params = [])
116
116
return new JobModule (
117
117
$ this ->serviceLocator ->get ('Magento\Setup\Console\Command\ModuleEnableCommand ' ),
118
118
$ objectManagerProvider ,
119
- $ multipleStreamOutput ,
119
+ $ streamOutput ,
120
120
$ cronStatus ,
121
121
$ name ,
122
122
$ params
@@ -126,26 +126,19 @@ public function create($name, array $params = [])
126
126
return new JobModule (
127
127
$ this ->serviceLocator ->get ('Magento\Setup\Console\Command\ModuleDisableCommand ' ),
128
128
$ objectManagerProvider ,
129
- $ multipleStreamOutput ,
129
+ $ streamOutput ,
130
130
$ cronStatus ,
131
131
$ name ,
132
132
$ params
133
133
);
134
134
break ;
135
135
case self ::JOB_ENABLE_CACHE :
136
136
$ cmd = $ objectManager ->get ('Magento\Backend\Console\Command\CacheEnableCommand ' );
137
- return new JobSetCache (
138
- $ cmd ,
139
- $ objectManagerProvider ,
140
- $ multipleStreamOutput ,
141
- $ cronStatus ,
142
- $ name ,
143
- $ params
144
- );
137
+ return new JobSetCache ($ cmd , $ objectManagerProvider , $ streamOutput , $ cronStatus , $ name , $ params );
145
138
break ;
146
139
case self ::JOB_DISABLE_CACHE :
147
140
$ cmd = $ objectManager ->get ('Magento\Backend\Console\Command\CacheDisableCommand ' );
148
- return new JobSetCache ($ cmd , $ objectManagerProvider , $ multipleStreamOutput , $ cronStatus , $ name );
141
+ return new JobSetCache ($ cmd , $ objectManagerProvider , $ streamOutput , $ cronStatus , $ name );
149
142
break ;
150
143
default :
151
144
throw new \RuntimeException (sprintf ('"%s" job is not supported. ' , $ name ));
0 commit comments