From 82f287f74e64475b6c05ec3891920b94cf2d0962 Mon Sep 17 00:00:00 2001 From: Ryan Kanner Date: Tue, 24 Apr 2018 10:54:20 -0600 Subject: [PATCH] fixing some commands I accedentally broke --- src/CLI.php | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/src/CLI.php b/src/CLI.php index cb681fc..3bc8ff4 100644 --- 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' ) ); }