eventespresso / event-espresso-core

			$obj = $this->instantiate_batch_job_handler_from_classname( $batch_job_handler_class );

			$this->_job_parameters = new JobParameters( $this->_job_id, $batch_job_handler_class, $request_data );

			$response = $obj->create_job( $this->_job_parameters );

			if( ! $response instanceof JobStepResponse ) {

				throw new BatchRequestException(

					sprintf(

						__( 'The class implementing JobHandlerInterface did not return a JobStepResponse when create_job was called with %1$s. It needs to return one or throw an Exception', 'event_espresso' ),

						wp_json_encode( $request_data )

					)

				);

			}

			$success = $this->_job_parameters->save( true );

			if( ! $success ) {

				throw new BatchRequestException(

				);

			}

			$success = $this->_job_parameters->save( true );

			if( ! $success ) {

				throw new BatchRequestException(

					sprintf(

						__('Could not save job %1$s to the Wordpress Options table. These were the arguments used: %2$s', 'event_espresso'),

						$this->_job_id,

						wp_json_encode( $request_data )

					)

				);

			}

		} catch( \Exception $e ) {

			$response = $this->_get_error_response( $e, 'create_job' );

		}

			$handler_obj = $this->instantiate_batch_job_handler_from_classname( $this->_job_parameters->classname() );

			//continue it

			$response = $handler_obj->continue_job( $this->_job_parameters, $batch_size );

			if( ! $response instanceof JobStepResponse ) {

				throw new BatchRequestException(

					sprintf(

						__( 'The class implementing JobHandlerInterface did not return a JobStepResponse when continue_job was called with job %1$s. It needs to return one or throw an Exception', 'event_espresso' ),

						$this->_job_id

					)

				);

			}

			$this->_job_parameters->save();

		} catch( \Exception $e ) {

			$response = $this->_get_error_response( $e, 'continue_job' );

			$handler_obj = $this->instantiate_batch_job_handler_from_classname( $job_parameters->classname() );

			//continue it

			$response = $handler_obj->cleanup_job( $job_parameters );

			if( ! $response instanceof JobStepResponse ) {

				throw new BatchRequestException(

					sprintf(

						__( 'The class implementing JobHandlerInterface did not return a JobStepResponse when cleanup_job was called with job %1$s. It needs to return one or throw an Exception', 'event_espresso' ),

						$this->_job_id

					)

				);

			}

			$job_parameters->set_status( JobParameters::status_cleaned_up );

			$job_parameters->delete();

			return $response;