Merge pull request #118 from restackio/quickstartEndpoints

Quickstart with endpoint

Author: aboutphilippe

get_started/README.md

@@ -0,0 +1,67 @@
+# Restack AI - Quickstart
+
+This repository contains a quickstart for Restack.
+It demonstrates how to set up a basic workflow and functions.
+
+## Prerequisites
+
+- Docker (for running Restack)
+- Python 3.10 or higher
+
+## Start Restack
+
+To start the Restack, use the following Docker command:
+
+```bash
+docker run -d --pull always --name restack -p 5233:5233 -p 6233:6233 -p 7233:7233 ghcr.io/restackio/restack:main
+```
+
+## Install dependencies and start services
+
+```bash
+poetry env use 3.10
+```
+
+```bash
+poetry shell
+```
+
+```bash
+poetry install
+```
+
+```bash
+poetry env info # Optional: copy the interpreter path to use in your IDE (e.g. Cursor, VSCode, etc.)
+```
+
+```bash
+poetry run dev
+```
+
+## Run workflows
+
+### from UI
+
+You can run workflows from the UI by clicking the "Run" button.
+
+![Run workflows from UI](./screenshot-quickstart.png)
+
+### from API
+
+You can run workflows from the API by using the generated endpoint:
+
+`POST http://localhost:6233/api/workflows/GreetingWorkflow`
+
+### from any client
+
+You can run workflows with any client connected to Restack, for example:
+
+```bash
+poetry run schedule
+```
+
+executes `schedule_workflow.py` which will connect to Restack and execute the `GreetingWorkflow` workflow.
+
+## Deploy on Restack Cloud
+
+To deploy the application on Restack, you can create an account at [https://console.restack.io](https://console.restack.io)

get_started/src/client.py

@@ -1,8 +1,8 @@
 # Project metadata
 [tool.poetry]
-name = "get_started"
+name = "quickstart"
 version = "0.0.1"
-description = "A simple example to get started with the restack-ai SDK"
+description = "A quickstart for Restack"
 authors = [
     "Restack Team <[email protected]>",
 ]
@@ -11,13 +11,11 @@ packages = [{include = "src"}]
 
 [tool.poetry.dependencies]
 python = ">=3.10,<4.0"
-restack-ai = "^0.0.48"
 watchfiles = "^1.0.0"
-
-[tool.poetry.dev-dependencies]
-pytest = "6.2"  # Optional: Add if you want to include tests in your example
+pydantic = "^2.10.4"
 
 # Build system configuration
+restack-ai = "^0.0.52"
 [build-system]
 requires = ["poetry-core"]
 build-backend = "poetry.core.masonry.api"

get_started/src/workflows/workflow.py

@@ -2,7 +2,7 @@
 import time
 from restack_ai import Restack
 from restack_ai.restack import ScheduleSpec, ScheduleCalendarSpec, ScheduleRange
-
+from src.workflows.workflow import GreetingWorkflowInput
 async def main():
 
     client = Restack()
@@ -11,6 +11,7 @@ async def main():
     await client.schedule_workflow(
         workflow_name="GreetingWorkflow",
         workflow_id=workflow_id,
+        input=GreetingWorkflowInput(name="Bob"),
         schedule=ScheduleSpec(
             calendars=[ScheduleCalendarSpec(
                 day_of_week=[ScheduleRange(start=1)],

get_started/.env.Example quickstart/.env.Exampleget_started/.env.Example renamed to quickstart/.env.Example

@@ -3,7 +3,7 @@
 from restack_ai import Restack
 from restack_ai.restack import ScheduleSpec, ScheduleIntervalSpec
 from datetime import timedelta
-
+from src.workflows.workflow import GreetingWorkflowInput
 async def main():
 
     client = Restack()
@@ -12,6 +12,7 @@ async def main():
     await client.schedule_workflow(
         workflow_name="GreetingWorkflow",
         workflow_id=workflow_id,
+        input=GreetingWorkflowInput(name="Bob"),
         schedule=ScheduleSpec(
             intervals=[ScheduleIntervalSpec(
                 every=timedelta(minutes=10)

get_started/.gitignore quickstart/.gitignoreget_started/.gitignore renamed to quickstart/.gitignore

@@ -1,15 +1,16 @@
 import asyncio
 import time
 from restack_ai import Restack
-
+from src.workflows.workflow import GreetingWorkflowInput
 async def main():
 
     client = Restack()
 
     workflow_id = f"{int(time.time() * 1000)}-GreetingWorkflow"
     run_id = await client.schedule_workflow(
         workflow_name="GreetingWorkflow",
-        workflow_id=workflow_id
+        workflow_id=workflow_id,
+        input=GreetingWorkflowInput(name="Bob")
     )
 
     await client.get_workflow_result(