Respect doing_cron transient in wp cron event run --due-now

features/cron-event.feature

@@ -244,3 +244,35 @@ Feature: Manage WP Cron events
       """
       Debug: Beginning execution of cron event 'wp_version_check'
       """
+
+  Scenario: --due-now respects the doing_cron transient and skips when another run is in progress
+    When I run `wp cron event schedule wp_cli_test_event_lock now hourly`
+    Then STDOUT should contain:
+      """
+      Success: Scheduled event with hook 'wp_cli_test_event_lock'
+      """
+
+    # Simulate an in-progress cron run by setting the doing_cron transient to now.
+    When I run `wp eval 'set_transient( "doing_cron", sprintf( "%.22F", microtime( true ) ) );'`
+
+    And I try `wp cron event run --due-now`
+    Then STDERR should contain:
+      """
+      Warning: A cron event run is already in progress; skipping.
+      """
+    And STDOUT should not contain:
+      """
+      wp_cli_test_event_lock
+      """
+
+    # After the transient is cleared, the run should proceed normally.
+    When I run `wp transient delete doing_cron`
+    And I try `wp cron event run --due-now`
+    Then STDOUT should contain:
+      """
+      Executed the cron event 'wp_cli_test_event_lock'
+      """
+    And STDOUT should contain:
+      """
+      Executed a total of 1 cron event
+      """

src/Cron_Event_Command.php

@@ -226,7 +226,8 @@ public function schedule( $args, $assoc_args ) {
 	 * : One or more hooks to run.
 	 *
 	 * [--due-now]
-	 * : Run all hooks due right now.
+	 * : Run all hooks due right now. Respects the doing_cron transient to
+	 * prevent overlapping runs.
 	 *
 	 * [--exclude=<hooks>]
 	 * : Comma-separated list of hooks to exclude.
@@ -243,10 +244,24 @@ public function schedule( $args, $assoc_args ) {
 	 *     Success: Executed a total of 2 cron events.
 	 */
 	public function run( $args, $assoc_args ) {
+		$due_now = Utils\get_flag_value( $assoc_args, 'due-now' );
+
+		if ( $due_now ) {
+			$lock_timeout         = defined( 'WP_CRON_LOCK_TIMEOUT' ) ? WP_CRON_LOCK_TIMEOUT : 60;
+			$doing_cron_transient = get_transient( 'doing_cron' );
+			if ( is_string( $doing_cron_transient ) && (float) $doing_cron_transient > microtime( true ) - $lock_timeout ) {
+				WP_CLI::warning( 'A cron event run is already in progress; skipping.' );
+				return;
+			}
+			set_transient( 'doing_cron', sprintf( '%.22F', microtime( true ) ) );
+		}
 
 		$events = self::get_selected_cron_events( $args, $assoc_args );
 
 		if ( is_wp_error( $events ) ) {
+			if ( $due_now ) {
+				delete_transient( 'doing_cron' );
+			}
 			WP_CLI::error( $events );
 		}
 
@@ -263,6 +278,10 @@ public function run( $args, $assoc_args ) {
 			}
 		}
 
+		if ( $due_now ) {
+			delete_transient( 'doing_cron' );
+		}
+
 		$message = ( 1 === $executed ) ? 'Executed a total of %d cron event.' : 'Executed a total of %d cron events.';
 		WP_CLI::success( sprintf( $message, $executed ) );
 	}