diff --git a/skyvern/exceptions.py b/skyvern/exceptions.py
index 6dd0ba4661..e5b976a1ef 100644
--- a/skyvern/exceptions.py
+++ b/skyvern/exceptions.py
@@ -495,3 +495,10 @@ def __init__(self, data: dict | None = None) -> None:
 class CachedActionPlanError(SkyvernException):
     def __init__(self, message: str) -> None:
         super().__init__(message)
+
+
+class InvalidUrl(SkyvernHTTPException):
+    def __init__(self, url: str) -> None:
+        super().__init__(
+            f"Invalid URL: {url}. Skyvern supports HTTP and HTTPS urls.", status_code=status.HTTP_400_BAD_REQUEST
+        )
diff --git a/skyvern/forge/agent.py b/skyvern/forge/agent.py
index 31963614b3..61bdc71cd4 100644
--- a/skyvern/forge/agent.py
+++ b/skyvern/forge/agent.py
@@ -36,6 +36,7 @@
 from skyvern.forge.sdk.artifact.models import ArtifactType
 from skyvern.forge.sdk.core import skyvern_context
 from skyvern.forge.sdk.core.security import generate_skyvern_signature
+from skyvern.forge.sdk.core.validators import validate_url
 from skyvern.forge.sdk.models import Organization, Step, StepStatus
 from skyvern.forge.sdk.schemas.tasks import Task, TaskRequest, TaskStatus
 from skyvern.forge.sdk.settings_manager import SettingsManager
@@ -126,6 +127,7 @@ async def create_task_and_step_from_block(
 
             task_url = working_page.url
 
+        task_url = validate_url(task_url)
         task = await app.DATABASE.create_task(
             url=task_url,
             title=task_block.title,
@@ -183,10 +185,10 @@ async def create_task_and_step_from_block(
 
     async def create_task(self, task_request: TaskRequest, organization_id: str | None = None) -> Task:
         task = await app.DATABASE.create_task(
-            url=task_request.url,
+            url=str(task_request.url),
             title=task_request.title,
-            webhook_callback_url=task_request.webhook_callback_url,
-            totp_verification_url=task_request.totp_verification_url,
+            webhook_callback_url=str(task_request.webhook_callback_url),
+            totp_verification_url=str(task_request.totp_verification_url),
             totp_identifier=task_request.totp_identifier,
             navigation_goal=task_request.navigation_goal,
             data_extraction_goal=task_request.data_extraction_goal,
diff --git a/skyvern/forge/sdk/core/validators.py b/skyvern/forge/sdk/core/validators.py
new file mode 100644
index 0000000000..c2107fb090
--- /dev/null
+++ b/skyvern/forge/sdk/core/validators.py
@@ -0,0 +1,13 @@
+from pydantic import HttpUrl, ValidationError, parse_obj_as
+
+from skyvern.exceptions import InvalidUrl
+
+
+def validate_url(url: str) -> str:
+    try:
+        # Use parse_obj_as to validate the string as an HttpUrl
+        parse_obj_as(HttpUrl, url)
+        return url
+    except ValidationError:
+        # Handle the validation error
+        raise InvalidUrl(url=url)
diff --git a/skyvern/forge/sdk/schemas/tasks.py b/skyvern/forge/sdk/schemas/tasks.py
index 08bead2bc4..11e5bb456a 100644
--- a/skyvern/forge/sdk/schemas/tasks.py
+++ b/skyvern/forge/sdk/schemas/tasks.py
@@ -4,7 +4,7 @@
 from enum import StrEnum
 from typing import Any
 
-from pydantic import BaseModel, Field
+from pydantic import BaseModel, Field, HttpUrl
 
 from skyvern.exceptions import InvalidTaskStatusTransition, TaskAlreadyCanceled
 
@@ -22,7 +22,7 @@ class ProxyLocation(StrEnum):
     NONE = "NONE"
 
 
-class TaskRequest(BaseModel):
+class TaskBase(BaseModel):
     title: str | None = Field(
         default=None,
         description="The title of the task.",
@@ -76,6 +76,20 @@ class TaskRequest(BaseModel):
     )
 
 
+class TaskRequest(TaskBase):
+    url: HttpUrl = Field(
+        ...,
+        description="Starting URL for the task.",
+        examples=["https://www.geico.com"],
+    )
+    webhook_callback_url: HttpUrl | None = Field(
+        default=None,
+        description="The URL to call when the task is completed.",
+        examples=["https://my-webhook.com"],
+    )
+    totp_verification_url: HttpUrl | None = None
+
+
 class TaskStatus(StrEnum):
     created = "created"
     queued = "queued"
@@ -144,7 +158,7 @@ def requires_failure_reason(self) -> bool:
         return self in status_requires_failure_reason
 
 
-class Task(TaskRequest):
+class Task(TaskBase):
     created_at: datetime = Field(
         ...,
         description="The creation datetime of the task.",
@@ -229,7 +243,7 @@ def to_task_response(
 
 
 class TaskResponse(BaseModel):
-    request: TaskRequest
+    request: TaskBase
     task_id: str
     status: TaskStatus
     created_at: datetime