delete_batch_job
Remove a specified batch job from Google Cloud Dataproc by providing the project ID, region, and batch job ID. Simplifies batch job management within the Dataproc MCP Server.
Instructions
Delete a batch job.
Args:
project_id: Google Cloud project ID
region: Dataproc region
batch_id: Batch job ID to delete
Input Schema
TableJSON Schema
| Name | Required | Description | Default |
|---|---|---|---|
| batch_id | Yes | ||
| project_id | Yes | ||
| region | Yes |
Implementation Reference
- MCP tool handler for 'delete_batch_job', registered via @mcp.tool() decorator. Delegates to DataprocBatchClient's delete_batch_job method.@mcp.tool() async def delete_batch_job(project_id: str, region: str, batch_id: str) -> str: """Delete a batch job. Args: project_id: Google Cloud project ID region: Dataproc region batch_id: Batch job ID to delete """ batch_client = DataprocBatchClient() try: result = await batch_client.delete_batch_job(project_id, region, batch_id) return str(result) except Exception as e: logger.error("Failed to delete batch job", error=str(e)) return f"Error: {str(e)}"
- Core helper function in DataprocBatchClient that performs the actual API call to delete the batch job using Google Cloud Dataproc BatchControllerClient.async def delete_batch_job( self, project_id: str, region: str, batch_id: str ) -> dict[str, Any]: """Delete a batch job.""" try: loop = asyncio.get_event_loop() client = self._get_batch_client(region) request = types.DeleteBatchRequest( name=f"projects/{project_id}/locations/{region}/batches/{batch_id}" ) await loop.run_in_executor(None, client.delete_batch, request) return { "batch_id": batch_id, "status": "DELETED", "message": f"Batch job {batch_id} deletion initiated", } except Exception as e: logger.error("Failed to delete batch job", error=str(e)) raise