Merge pull request #54 from CodeProKid/cli-command-fixes

hughdevore · web-flow · commit 3bcd0eedf6af · 2018-04-24T11:17:33.000-06:00
fixing some commands I accidentally broke
diff --git a/src/CLI.php b/src/CLI.php
@@ -145,8 +145,11 @@ public function process( $args, $assoc_args ) {
 		}
 
 		\WP_CLI::log( __( 'Starting Processor', 'wp-queue-tasks' ) );
+		$lock = uniqid();
+		Utils::lock_queue_process( $queue_name, $lock );
 		$processor_obj = new Processor();
-		$processor_obj->run_processor( $queue_name, $queue_term->term_id );
+		$processor_obj->run_processor( $queue_name, $queue_term->term_id, $lock );
+		Utils::unlock_queue_process( $queue_name );
 		\WP_CLI::log( __( 'Processor ran', 'wp-queue-tasks' ) );
 
 	}

Original file line number	Diff line number	Diff line change
`@@ -145,8 +145,11 @@ public function process( $args, $assoc_args ) {`
`145`	`145`	`}`
`146`	`146`
`147`	`147`	`\WP_CLI::log( __( 'Starting Processor', 'wp-queue-tasks' ) );`
	`148`	`+ $lock = uniqid();`
	`149`	`+ Utils::lock_queue_process( $queue_name, $lock );`
`148`	`150`	`$processor_obj = new Processor();`
`149`		`- $processor_obj->run_processor( $queue_name, $queue_term->term_id );`
	`151`	`+ $processor_obj->run_processor( $queue_name, $queue_term->term_id, $lock );`
	`152`	`+ Utils::unlock_queue_process( $queue_name );`
`150`	`153`	`\WP_CLI::log( __( 'Processor ran', 'wp-queue-tasks' ) );`
`151`	`154`
`152`	`155`	`}`