diff --git a/api-nodes/Http/Controllers/EventController.php b/api-nodes/Http/Controllers/EventController.php
index 17fbb73..28965e3 100644
--- a/api-nodes/Http/Controllers/EventController.php
+++ b/api-nodes/Http/Controllers/EventController.php
@@ -14,8 +14,6 @@ public function started(Node $node, NodeData $data)
 
         $node->save();
 
-        dd($node->data);
-
         return [
             'settings' => [
                 'poll_interval' => 5
diff --git a/api-nodes/Http/Controllers/NextTaskController.php b/api-nodes/Http/Controllers/NextTaskController.php
new file mode 100644
index 0000000..7b29556
--- /dev/null
+++ b/api-nodes/Http/Controllers/NextTaskController.php
@@ -0,0 +1,54 @@
+<?php
+
+namespace ApiNodes\Http\Controllers;
+
+use App\Models\Node;
+use App\Models\NodeTask\TaskStatus;
+use App\Models\NodeTaskGroup;
+use Illuminate\Database\Eloquent\Builder;
+use Illuminate\Http\Response;
+
+class NextTaskController
+{
+    public function __invoke(Node $node)
+    {
+        $taskGroup = $node->taskGroups()->inProgress()->first();
+
+        $task = $taskGroup ? $this->getNextTaskFromGroup($taskGroup) : $this->pickNextTask($node);
+        if ($task) {
+            return $task;
+        }
+
+        return new Response([
+            'message' => 'No task found.'
+        ], 404);
+    }
+
+    protected function getNextTaskFromGroup(NodeTaskGroup $taskGroup)
+    {
+        if ($taskGroup->tasks()->running()->first()) {
+            return new Response([
+                'error_message' => 'Another task should be already running.'
+            ], 409);
+        }
+
+        $task = $taskGroup->tasks()->pending()->first();
+
+        $task->start();
+
+        return $task;
+    }
+
+    protected function pickNextTask(Node $node)
+    {
+        $taskGroup = NodeTaskGroup::where('swarm_id', $node->swarm_id)->where(function (Builder $query) use ($node) {
+            return $query->where('node_id', $node->id)->orWhere('node_id', null);
+        })->pending()->first();
+
+        $task = $taskGroup->tasks()->first();
+
+        $taskGroup->startTask($node, $task);
+
+        return $task;
+    }
+}
\ No newline at end of file
diff --git a/api-nodes/Http/Controllers/TaskController.php b/api-nodes/Http/Controllers/TaskController.php
new file mode 100644
index 0000000..935804f
--- /dev/null
+++ b/api-nodes/Http/Controllers/TaskController.php
@@ -0,0 +1,46 @@
+<?php
+
+namespace ApiNodes\Http\Controllers;
+
+use App\Casts\TaskResultCast;
+use App\Models\NodeTask;
+use App\Models\NodeTask\ErrorResult;
+use Illuminate\Http\Request;
+use Illuminate\Http\Response;
+
+class TaskController
+{
+    public function complete(NodeTask $task, Request $request)
+    {
+        if ($task->is_ended) {
+            return new Response(['error' => 'Already ended.'], 409);
+        }
+
+        if ($task->is_pending) {
+            return new Response(['error' => "Task didn't start yet."], 409);
+        }
+
+        $result = TaskResultCast::RESULT_BY_TYPE[$task->type]::validateAndCreate($request->all());
+
+        $task->complete($result);
+
+        return new Response('', 204);
+    }
+
+    public function fail(NodeTask $task, Request $request)
+    {
+        if ($task->is_ended) {
+            return new Response(['error' => 'Already ended.'], 409);
+        }
+
+        if ($task->is_pending) {
+            return new Response(['error' => "Task didn't start yet."], 409);
+        }
+
+        $result = ErrorResult::validateAndCreate($request->all());
+
+        $task->fail($result);
+
+        return new Response('', 204);
+    }
+}
\ No newline at end of file
diff --git a/api-nodes/Http/Middleware/AgentTokenAuth.php b/api-nodes/Http/Middleware/AgentTokenAuth.php
index a8bb372..14cc6e6 100644
--- a/api-nodes/Http/Middleware/AgentTokenAuth.php
+++ b/api-nodes/Http/Middleware/AgentTokenAuth.php
@@ -3,7 +3,9 @@
 namespace ApiNodes\Http\Middleware;
 
 use App\Models\Node;
+use App\Models\NodeTask;
 use App\Models\Scopes\TeamScope;
+use App\Models\Team;
 use Closure;
 use Illuminate\Http\Request;
 use Symfony\Component\HttpFoundation\Response;
@@ -34,6 +36,7 @@ public function handle(Request $request, Closure $next): Response
         $node->save();
 
         app()->singleton(Node::class, fn() => $node);
+        app()->singleton(Team::class, fn() => $node->team);
 
         return $next($request);
     }
diff --git a/app/Casts/TaskPayloadCast.php b/app/Casts/TaskPayloadCast.php
new file mode 100644
index 0000000..86e7086
--- /dev/null
+++ b/app/Casts/TaskPayloadCast.php
@@ -0,0 +1,51 @@
+<?php
+
+namespace App\Casts;
+
+use App\Models\NodeTask;
+use App\Models\NodeTask\CreateNetworkTaskPayload;
+use App\Models\NodeTask\InitSwarmTaskPayload;
+use Illuminate\Contracts\Database\Eloquent\CastsAttributes;
+use Illuminate\Database\Eloquent\Model;
+use InvalidArgumentException;
+
+class TaskPayloadCast implements CastsAttributes
+{
+    public const TYPE_BY_PAYLOAD = [
+        CreateNetworkTaskPayload::class => 0,
+        InitSwarmTaskPayload::class => 1
+    ];
+
+    public const PAYLOAD_BY_TYPE = [
+        0 => CreateNetworkTaskPayload::class,
+        1 => InitSwarmTaskPayload::class
+    ];
+
+    /**
+     * Cast the given value.
+     *
+     * @param  array<string, mixed>  $attributes
+     */
+    public function get(Model $model, string $key, mixed $value, array $attributes): mixed
+    {
+        if (!($model instanceof NodeTask)) {
+            throw new InvalidArgumentException('Model must be an instance of NodeTask');
+        }
+
+        return self::PAYLOAD_BY_TYPE[$model->type]::from($value);
+    }
+
+    /**
+     * Prepare the given value for storage.
+     *
+     * @param  array<string, mixed>  $attributes
+     */
+    public function set(Model $model, string $key, mixed $value, array $attributes): mixed
+    {
+        if (!($model instanceof NodeTask)) {
+            throw new InvalidArgumentException('Model must be an instance of NodeTask');
+        }
+
+        return $value->toJson();
+    }
+}
diff --git a/app/Casts/TaskResultCast.php b/app/Casts/TaskResultCast.php
new file mode 100644
index 0000000..4e9401b
--- /dev/null
+++ b/app/Casts/TaskResultCast.php
@@ -0,0 +1,61 @@
+<?php
+
+namespace App\Casts;
+
+use App\Models\NodeTask;
+use App\Models\NodeTask\CreateNetworkTaskResult;
+use App\Models\NodeTask\ErrorResult;
+use App\Models\NodeTask\InitSwarmTaskResult;
+use InvalidArgumentException;
+use Illuminate\Contracts\Database\Eloquent\CastsAttributes;
+use Illuminate\Database\Eloquent\Model;
+
+class TaskResultCast implements CastsAttributes
+{
+
+    public const TYPE_BY_RESULT = [
+        CreateNetworkTaskResult::class => 0,
+        InitSwarmTaskResult::class => 1
+    ];
+
+    public const RESULT_BY_TYPE = [
+        0 => CreateNetworkTaskResult::class,
+        1 => InitSwarmTaskResult::class
+    ];
+
+    /**
+     * Cast the given value.
+     *
+     * @param  array<string, mixed>  $attributes
+     */
+    public function get(Model $model, string $key, mixed $value, array $attributes): mixed
+    {
+        if (!($model instanceof NodeTask)) {
+            throw new InvalidArgumentException('Model must be an instance of NodeTask');
+        }
+
+        if ($model->is_failed) {
+            return ErrorResult::from($value);
+        }
+
+        if ($model->is_ended) {
+            return self::RESULT_BY_TYPE[$model->type]::from($value);
+        }
+
+        return null;
+    }
+
+    /**
+     * Prepare the given value for storage.
+     *
+     * @param  array<string, mixed>  $attributes
+     */
+    public function set(Model $model, string $key, mixed $value, array $attributes): mixed
+    {
+        if (!($model instanceof NodeTask)) {
+            throw new InvalidArgumentException('Model must be an instance of NodeTask');
+        }
+
+        return $value->toJson();
+    }
+}
diff --git a/app/Http/Controllers/NodeController.php b/app/Http/Controllers/NodeController.php
index 9cf2262..26c20f9 100644
--- a/app/Http/Controllers/NodeController.php
+++ b/app/Http/Controllers/NodeController.php
@@ -5,6 +5,8 @@
 use App\Http\Requests\StoreNodeRequest;
 use App\Http\Requests\UpdateNodeRequest;
 use App\Models\Node;
+use App\Models\NodeTask;
+use App\Models\NodeTask\InitSwarmTaskPayload;
 use Inertia\Inertia;
 
 class NodeController extends Controller
@@ -40,7 +42,12 @@ public function store(StoreNodeRequest $request)
      */
     public function show(Node $node)
     {
-        return Inertia::render('Nodes/Show', ['node' => $node]);
+        $initTaskGroup = $node->tasks()->inProgress()->ofType(InitSwarmTaskPayload::class)->first()?->taskGroup->with('tasks')->first();
+        if (!$initTaskGroup) {
+            $initTaskGroup = $node->tasks()->failed()->ofType(InitSwarmTaskPayload::class)->first()?->taskGroup->with('tasks')->first();
+        }
+
+        return Inertia::render('Nodes/Show', ['node' => $node, 'initTaskGroup' => $initTaskGroup]);
     }
 
     /**
diff --git a/app/Http/Controllers/SwarmTaskController.php b/app/Http/Controllers/SwarmTaskController.php
new file mode 100644
index 0000000..6a009ca
--- /dev/null
+++ b/app/Http/Controllers/SwarmTaskController.php
@@ -0,0 +1,39 @@
+<?php
+
+namespace App\Http\Controllers;
+
+use App\Http\Requests\NodeTask\InitClusterFormRequest;
+use App\Models\Node;
+use App\Models\NodeTask\CreateNetworkTaskPayload;
+use App\Models\NodeTask\InitSwarmTaskPayload;
+use App\Models\NodeTaskGroup;
+use App\Models\Swarm;
+
+class SwarmTaskController extends Controller
+{
+    public function initCluster(InitClusterFormRequest $request)
+    {
+        $swarm = Swarm::create([
+            'name' => $request->name,
+        ]);
+
+        Node::whereId($request->node_id)->update([
+            'swarm_id' => $swarm->id,
+        ]);
+
+        $taskGroup = NodeTaskGroup::create([
+            'swarm_id' => $swarm->id,
+            'node_id' => $request->node_id,
+            'invoker_id' => auth()->user()->id,
+        ]);
+
+        $taskGroup->tasks()->createMany([
+            [
+                'payload' => new CreateNetworkTaskPayload('ptah-net'),
+            ],
+            [
+                'payload' => new InitSwarmTaskPayload($request->name, $request->force_new_cluster),
+            ]
+        ]);
+    }
+}
\ No newline at end of file
diff --git a/app/Http/Requests/NodeTask/InitClusterFormRequest.php b/app/Http/Requests/NodeTask/InitClusterFormRequest.php
new file mode 100644
index 0000000..2613cdf
--- /dev/null
+++ b/app/Http/Requests/NodeTask/InitClusterFormRequest.php
@@ -0,0 +1,23 @@
+<?php
+
+namespace App\Http\Requests\NodeTask;
+
+use Illuminate\Foundation\Http\FormRequest;
+
+class InitClusterFormRequest extends FormRequest
+{
+    public function authorize(): bool
+    {
+        return true;
+    }
+
+    public function rules(): array
+    {
+        return [
+            'node_id' => ['required'],
+            'name' => ['required', 'string', 'max:255'],
+            'advertise_addr' => ['required', 'ipv4'],
+            'force_new_cluster' => ['boolean'],
+        ];
+    }
+}
\ No newline at end of file
diff --git a/app/Models/Node.php b/app/Models/Node.php
index 3537f81..2cc8a0a 100644
--- a/app/Models/Node.php
+++ b/app/Models/Node.php
@@ -2,10 +2,11 @@
 
 namespace App\Models;
 
-use App\HasOwningTeam;
+use App\Traits\HasOwningTeam;
 use Illuminate\Database\Eloquent\Factories\HasFactory;
 use Illuminate\Database\Eloquent\Model;
-use Illuminate\Support\Facades\Auth;
+use Illuminate\Database\Eloquent\Relations\HasMany;
+use Illuminate\Database\Eloquent\Relations\HasManyThrough;
 use Illuminate\Support\Str;
 
 class Node extends Model
@@ -32,6 +33,16 @@ protected static function booted()
         });
     }
 
+    public function taskGroups(): HasMany
+    {
+        return $this->hasMany(NodeTaskGroup::class);
+    }
+
+    public function tasks(): HasManyThrough
+    {
+        return $this->hasManyThrough(NodeTask::class, NodeTaskGroup::class, 'node_id', 'task_group_id', 'id', 'id');
+    }
+
     public function getOnlineAttribute()
     {
         return true;
diff --git a/app/Models/NodeTask.php b/app/Models/NodeTask.php
new file mode 100644
index 0000000..0c0d585
--- /dev/null
+++ b/app/Models/NodeTask.php
@@ -0,0 +1,119 @@
+<?php
+
+namespace App\Models;
+
+use App\Casts\TaskPayloadCast;
+use App\Casts\TaskResultCast;
+use App\Models\NodeTask\AbstractTaskPayload;
+use App\Models\NodeTask\AbstractTaskResult;
+use App\Models\NodeTask\CreateNetworkTaskPayload;
+use App\Models\NodeTask\InitSwarmTaskPayload;
+use App\Models\NodeTask\TaskStatus;
+use App\Traits\HasOwningTeam;
+use App\Traits\HasTaskStatus;
+use DASPRiD\Enum\Exception\IllegalArgumentException;
+use Illuminate\Database\Eloquent\Factories\HasFactory;
+use Illuminate\Database\Eloquent\Model;
+use Illuminate\Database\Eloquent\Relations\BelongsTo;
+
+class NodeTask extends Model
+{
+    use HasFactory;
+    use HasOwningTeam;
+    use HasTaskStatus;
+
+    protected $fillable = [
+        'payload'
+    ];
+
+    protected $casts = [
+        'payload' => TaskPayloadCast::class,
+        'result' => TaskResultCast::class
+    ];
+
+    protected $appends = [
+        'formatted_payload',
+        'formatted_result',
+    ];
+
+    protected static function booted()
+    {
+        self::creating(function (NodeTask $nodeTask) {
+            $nodeTask->type = TaskPayloadCast::TYPE_BY_PAYLOAD[get_class($nodeTask->payload)];
+        });
+    }
+
+    public function taskGroup(): BelongsTo
+    {
+        return $this->belongsTo(NodeTaskGroup::class);
+    }
+
+    public function getFormattedPayloadAttribute(): string
+    {
+        return $this->payload->formattedHtml();
+    }
+
+    public function getFormattedResultAttribute(): string | null
+    {
+        if (is_null($this->result)) {
+            return null;
+        }
+
+        return $this->result->formattedHtml();
+    }
+
+    public function getIsEndedAttribute()
+    {
+        return $this->status->isEnded();
+    }
+
+    public function getIsPendingAttribute()
+    {
+        return $this->status === TaskStatus::Pending;
+    }
+
+    public function getIsFailedAttribute()
+    {
+        return $this->status === TaskStatus::Failed;
+    }
+
+    /**
+     * @throws IllegalArgumentException
+     */
+    public function setPayloadAttribute($payload): void
+    {
+        if (!($payload instanceof AbstractTaskPayload)) {
+            throw new IllegalArgumentException('Payload must be an instance of AbstractTaskPayload');
+        }
+
+        $this->attributes['payload'] = $payload;
+    }
+
+    public function start(): void
+    {
+        $this->status = TaskStatus::Running;
+        $this->started_at = now();
+        $this->save();
+    }
+
+    public function complete(AbstractTaskResult $result): void
+    {
+        $this->status = TaskStatus::Completed;
+
+        $this->endTask($result);
+    }
+
+    public function fail(AbstractTaskResult $result): void
+    {
+        $this->status = TaskStatus::Failed;
+
+        $this->endTask($result);
+    }
+
+    protected function endTask(AbstractTaskResult $result): void
+    {
+        $this->ended_at = now();
+        $this->result = $result;
+        $this->save();
+    }
+}
diff --git a/app/Models/NodeTask/AbstractTaskPayload.php b/app/Models/NodeTask/AbstractTaskPayload.php
new file mode 100644
index 0000000..358633a
--- /dev/null
+++ b/app/Models/NodeTask/AbstractTaskPayload.php
@@ -0,0 +1,9 @@
+<?php
+
+namespace App\Models\NodeTask;
+
+use Spatie\LaravelData\Data;
+
+abstract class AbstractTaskPayload extends Data {
+    abstract public function formattedHtml();
+}
diff --git a/app/Models/NodeTask/AbstractTaskResult.php b/app/Models/NodeTask/AbstractTaskResult.php
new file mode 100644
index 0000000..4656e3d
--- /dev/null
+++ b/app/Models/NodeTask/AbstractTaskResult.php
@@ -0,0 +1,10 @@
+<?php
+
+namespace App\Models\NodeTask;
+
+use Spatie\LaravelData\Data;
+
+abstract class AbstractTaskResult extends Data
+{
+    abstract public function formattedHtml();
+}
\ No newline at end of file
diff --git a/app/Models/NodeTask/CreateNetworkTaskPayload.php b/app/Models/NodeTask/CreateNetworkTaskPayload.php
new file mode 100644
index 0000000..ab16f95
--- /dev/null
+++ b/app/Models/NodeTask/CreateNetworkTaskPayload.php
@@ -0,0 +1,17 @@
+<?php
+
+namespace App\Models\NodeTask;
+
+class CreateNetworkTaskPayload extends AbstractTaskPayload
+{
+    public function __construct(
+        public string $name,
+    ) {
+
+    }
+
+    public function formattedHtml(): string
+    {
+        return 'Create Docker Network <code>'.$this->name.'</code>';
+    }
+}
\ No newline at end of file
diff --git a/app/Models/NodeTask/CreateNetworkTaskResult.php b/app/Models/NodeTask/CreateNetworkTaskResult.php
new file mode 100644
index 0000000..abf9658
--- /dev/null
+++ b/app/Models/NodeTask/CreateNetworkTaskResult.php
@@ -0,0 +1,19 @@
+<?php
+
+namespace App\Models\NodeTask;
+
+use Spatie\LaravelData\Data;
+
+class CreateNetworkTaskResult extends AbstractTaskResult
+{
+    public function __construct(
+        public DockerId $docker
+    ) {
+
+    }
+
+    public function formattedHtml(): string
+    {
+        return 'Network ID: <code>' . $this->docker->id . '</code>';
+    }
+}
\ No newline at end of file
diff --git a/app/Models/NodeTask/DockerId.php b/app/Models/NodeTask/DockerId.php
new file mode 100644
index 0000000..71c84c4
--- /dev/null
+++ b/app/Models/NodeTask/DockerId.php
@@ -0,0 +1,14 @@
+<?php
+
+namespace App\Models\NodeTask;
+
+use Spatie\LaravelData\Data;
+
+class DockerId extends Data {
+
+    public function __construct(
+        public string $id
+    ) {
+
+    }
+}
\ No newline at end of file
diff --git a/app/Models/NodeTask/ErrorResult.php b/app/Models/NodeTask/ErrorResult.php
new file mode 100644
index 0000000..eecf248
--- /dev/null
+++ b/app/Models/NodeTask/ErrorResult.php
@@ -0,0 +1,18 @@
+<?php
+
+namespace App\Models\NodeTask;
+
+class ErrorResult extends AbstractTaskResult
+{
+    public function __construct(
+        public string $message
+    )
+    {
+
+    }
+
+    public function formattedHtml(): string
+    {
+        return $this->message;
+    }
+}
\ No newline at end of file
diff --git a/app/Models/NodeTask/InitSwarmTaskPayload.php b/app/Models/NodeTask/InitSwarmTaskPayload.php
new file mode 100644
index 0000000..8cf3ab9
--- /dev/null
+++ b/app/Models/NodeTask/InitSwarmTaskPayload.php
@@ -0,0 +1,23 @@
+<?php
+
+namespace App\Models\NodeTask;
+
+class InitSwarmTaskPayload extends AbstractTaskPayload
+{
+    public function __construct(
+        public string $name,
+        public bool $forceNewCluster
+    ) {
+
+    }
+
+    public function formattedHtml(): string
+    {
+        $msg = 'Initialize Docker Swarm cluster <code>'.$this->name.'</code>';
+        if ($this->forceNewCluster) {
+            $msg .= ' with <b>force cluster creation</b>';
+        }
+
+        return $msg;
+    }
+}
\ No newline at end of file
diff --git a/app/Models/NodeTask/InitSwarmTaskResult.php b/app/Models/NodeTask/InitSwarmTaskResult.php
new file mode 100644
index 0000000..a7353e7
--- /dev/null
+++ b/app/Models/NodeTask/InitSwarmTaskResult.php
@@ -0,0 +1,20 @@
+<?php
+
+namespace App\Models\NodeTask;
+
+use Spatie\LaravelData\Data;
+
+class InitSwarmTaskResult extends AbstractTaskResult
+{
+    public function __construct(
+        public DockerId $docker
+    )
+    {
+
+    }
+
+    public function formattedHtml(): string
+    {
+        return 'Swarm ID: <code>' . $this->docker->id . '</code>';
+    }
+}
\ No newline at end of file
diff --git a/app/Models/NodeTask/TaskStatus.php b/app/Models/NodeTask/TaskStatus.php
new file mode 100644
index 0000000..095e7e4
--- /dev/null
+++ b/app/Models/NodeTask/TaskStatus.php
@@ -0,0 +1,19 @@
+<?php
+
+namespace App\Models\NodeTask;
+
+enum TaskStatus: string
+{
+    case Pending = 'pending';
+    case Running = 'running';
+    case Completed = 'completed';
+    case Failed = 'failed';
+    case Cancelled = 'cancelled';
+
+    public function isEnded(): bool
+    {
+        return $this->value === TaskStatus::Completed->value
+            || $this->value === TaskStatus::Failed->value
+            || $this->value === TaskStatus::Cancelled->value;
+    }
+}
\ No newline at end of file
diff --git a/app/Models/NodeTaskGroup.php b/app/Models/NodeTaskGroup.php
new file mode 100644
index 0000000..c1d2492
--- /dev/null
+++ b/app/Models/NodeTaskGroup.php
@@ -0,0 +1,49 @@
+<?php
+
+namespace App\Models;
+
+use App\Models\NodeTask\TaskStatus;
+use App\Traits\HasOwningTeam;
+use App\Traits\HasTaskStatus;
+use Illuminate\Database\Eloquent\Factories\HasFactory;
+use Illuminate\Database\Eloquent\Model;
+use Illuminate\Database\Eloquent\Relations\BelongsTo;
+use Illuminate\Database\Eloquent\Relations\HasMany;
+
+class NodeTaskGroup extends Model
+{
+    use HasFactory;
+    use HasOwningTeam;
+    use HasTaskStatus;
+
+    protected $fillable = [
+        'swarm_id',
+        'node_id',
+        'invoker_id',
+    ];
+
+    public function swarm(): BelongsTo
+    {
+        return $this->belongsTo(Swarm::class);
+    }
+
+    public function tasks(): HasMany
+    {
+        return $this->hasMany(NodeTask::class, 'task_group_id');
+    }
+
+    public function node(): BelongsTo
+    {
+        return $this->belongsTo(Node::class);
+    }
+
+    public function startTask(Node $node, NodeTask $task): void
+    {
+        $this->status = TaskStatus::Running;
+        $this->node_id = $node->id;
+        $this->started_at = now();
+        $this->save();
+
+        $task->start();
+    }
+}
diff --git a/app/Models/Scopes/TeamScope.php b/app/Models/Scopes/TeamScope.php
index 6af67d5..9870199 100644
--- a/app/Models/Scopes/TeamScope.php
+++ b/app/Models/Scopes/TeamScope.php
@@ -2,6 +2,7 @@
 
 namespace App\Models\Scopes;
 
+use App\Models\Team;
 use Illuminate\Database\Eloquent\Builder;
 use Illuminate\Database\Eloquent\Model;
 use Illuminate\Database\Eloquent\Scope;
@@ -13,6 +14,8 @@ class TeamScope implements Scope
      */
     public function apply(Builder $builder, Model $model): void
     {
-        $builder->where('team_id', auth()->user()->currentTeam->id);
+        $teamId = auth()->user()?->currentTeam->id ?: app(Team::class)->id;
+
+        $builder->where($builder->qualifyColumn('team_id'), $teamId);
     }
 }
diff --git a/app/Models/Swarm.php b/app/Models/Swarm.php
index 1a4f292..6d64d98 100644
--- a/app/Models/Swarm.php
+++ b/app/Models/Swarm.php
@@ -2,10 +2,22 @@
 
 namespace App\Models;
 
+use App\Traits\HasOwningTeam;
 use Illuminate\Database\Eloquent\Factories\HasFactory;
 use Illuminate\Database\Eloquent\Model;
+use Illuminate\Database\Eloquent\Relations\HasMany;
 
 class Swarm extends Model
 {
     use HasFactory;
+    use HasOwningTeam;
+
+    protected $fillable = [
+        'name'
+    ];
+
+    public function nodes(): HasMany
+    {
+        return $this->hasMany(Node::class);
+    }
 }
diff --git a/app/HasOwningTeam.php b/app/Traits/HasOwningTeam.php
similarity index 95%
rename from app/HasOwningTeam.php
rename to app/Traits/HasOwningTeam.php
index 464dc54..ce91f08 100644
--- a/app/HasOwningTeam.php
+++ b/app/Traits/HasOwningTeam.php
@@ -1,6 +1,6 @@
 <?php
 
-namespace App;
+namespace App\Traits;
 
 use App\Models\Scopes\TeamScope;
 use App\Models\Team;
diff --git a/app/Traits/HasTaskStatus.php b/app/Traits/HasTaskStatus.php
new file mode 100644
index 0000000..2f6350c
--- /dev/null
+++ b/app/Traits/HasTaskStatus.php
@@ -0,0 +1,49 @@
+<?php
+
+namespace App\Traits;
+
+use App\Casts\TaskPayloadCast;
+use App\Models\NodeTask\TaskStatus;
+use Illuminate\Database\Eloquent\Builder;
+
+trait HasTaskStatus
+{
+    protected static function bootHasTaskStatus(): void
+    {
+        static::addGlobalScope('taskStatusCast', function (Builder $builder) {
+            return $builder->withCasts([
+                'status' => TaskStatus::class
+            ])->orderBy('id');
+        });
+    }
+
+    public function scopePending(Builder $query): Builder
+    {
+        return $query->where($query->qualifyColumn('status'), TaskStatus::Pending);
+    }
+
+    public function scopeRunning(Builder $query): Builder
+    {
+        return $query->where($query->qualifyColumn('status'), TaskStatus::Running);
+    }
+
+    public function scopeFailed(Builder $builder): Builder
+    {
+        return $builder->where($builder->qualifyColumn('status'), TaskStatus::Failed);
+    }
+
+    public function getIsRunningAttribute() : bool
+    {
+        return $this->status === TaskStatus::Running;
+    }
+
+    public function scopeOfType(Builder $query, string $typeClass): Builder
+    {
+        return $query->where('type', TaskPayloadCast::TYPE_BY_PAYLOAD[$typeClass]);
+    }
+
+    public function scopeInProgress(Builder $query): Builder
+    {
+        return $query->whereIn($query->qualifyColumn('status'), [TaskStatus::Pending, TaskStatus::Running]);
+    }
+}
\ No newline at end of file
diff --git a/database/factories/NodeTaskFactory.php b/database/factories/NodeTaskFactory.php
new file mode 100644
index 0000000..99c4c05
--- /dev/null
+++ b/database/factories/NodeTaskFactory.php
@@ -0,0 +1,23 @@
+<?php
+
+namespace Database\Factories;
+
+use Illuminate\Database\Eloquent\Factories\Factory;
+
+/**
+ * @extends \Illuminate\Database\Eloquent\Factories\Factory<\App\Models\NodeTask>
+ */
+class NodeTaskFactory extends Factory
+{
+    /**
+     * Define the model's default state.
+     *
+     * @return array<string, mixed>
+     */
+    public function definition(): array
+    {
+        return [
+            //
+        ];
+    }
+}
diff --git a/database/factories/NodeTaskGroupFactory.php b/database/factories/NodeTaskGroupFactory.php
new file mode 100644
index 0000000..f2749a6
--- /dev/null
+++ b/database/factories/NodeTaskGroupFactory.php
@@ -0,0 +1,23 @@
+<?php
+
+namespace Database\Factories;
+
+use Illuminate\Database\Eloquent\Factories\Factory;
+
+/**
+ * @extends \Illuminate\Database\Eloquent\Factories\Factory<\App\Models\NodeTaskGroup>
+ */
+class NodeTaskGroupFactory extends Factory
+{
+    /**
+     * Define the model's default state.
+     *
+     * @return array<string, mixed>
+     */
+    public function definition(): array
+    {
+        return [
+            //
+        ];
+    }
+}
diff --git a/database/migrations/2024_06_19_184050_alter_nodes_add_data_column.php b/database/migrations/2024_06_19_184050_alter_nodes_add_data_column.php
index a9ddff1..44d3571 100644
--- a/database/migrations/2024_06_19_184050_alter_nodes_add_data_column.php
+++ b/database/migrations/2024_06_19_184050_alter_nodes_add_data_column.php
@@ -12,7 +12,7 @@
     public function up(): void
     {
         Schema::table('nodes', function (Blueprint $table) {
-            $table->json('data')->nullable();
+            $table->jsonb('data')->nullable();
         });
     }
 
diff --git a/database/migrations/2024_06_19_202417_create_node_task_groups_table.php b/database/migrations/2024_06_19_202417_create_node_task_groups_table.php
new file mode 100644
index 0000000..bb03b27
--- /dev/null
+++ b/database/migrations/2024_06_19_202417_create_node_task_groups_table.php
@@ -0,0 +1,34 @@
+<?php
+
+use Illuminate\Database\Migrations\Migration;
+use Illuminate\Database\Schema\Blueprint;
+use Illuminate\Support\Facades\Schema;
+
+return new class extends Migration
+{
+    /**
+     * Run the migrations.
+     */
+    public function up(): void
+    {
+        Schema::create('node_task_groups', function (Blueprint $table) {
+            $table->id();
+            $table->foreignId('team_id')->constrained()->cascadeOnDelete();
+            $table->foreignId('swarm_id')->constrained()->cascadeOnDelete();
+            $table->foreignId('node_id')->nullable()->constrained()->cascadeOnDelete();
+            $table->enum('status', ['pending', 'running', 'completed', 'failed', 'canceled'])->default('pending');
+            $table->foreignId('invoker_id')->constrained('users')->cascadeOnDelete();
+            $table->timestamp('started_at')->nullable();
+            $table->timestamp('ended_at')->nullable();
+            $table->timestamps();
+        });
+    }
+
+    /**
+     * Reverse the migrations.
+     */
+    public function down(): void
+    {
+        Schema::dropIfExists('node_task_groups');
+    }
+};
diff --git a/database/migrations/2024_06_19_204239_create_node_tasks_table.php b/database/migrations/2024_06_19_204239_create_node_tasks_table.php
new file mode 100644
index 0000000..5c8884f
--- /dev/null
+++ b/database/migrations/2024_06_19_204239_create_node_tasks_table.php
@@ -0,0 +1,35 @@
+<?php
+
+use Illuminate\Database\Migrations\Migration;
+use Illuminate\Database\Schema\Blueprint;
+use Illuminate\Support\Facades\Schema;
+
+return new class extends Migration
+{
+    /**
+     * Run the migrations.
+     */
+    public function up(): void
+    {
+        Schema::create('node_tasks', function (Blueprint $table) {
+            $table->id();
+            $table->foreignId('team_id')->constrained()->cascadeOnDelete();
+            $table->foreignId('task_group_id')->constrained('node_task_groups')->cascadeOnDelete();
+            $table->smallInteger('type');
+            $table->jsonb('payload');
+            $table->enum('status', ['pending', 'running', 'completed', 'failed', 'canceled'])->default('pending');
+            $table->timestamp('started_at')->nullable();
+            $table->timestamp('ended_at')->nullable();
+            $table->jsonb('result')->nullable();
+            $table->timestamps();
+        });
+    }
+
+    /**
+     * Reverse the migrations.
+     */
+    public function down(): void
+    {
+        Schema::dropIfExists('node_tasks');
+    }
+};
diff --git a/database/migrations/2024_06_20_142704_alter_nodes_add_swarm_id_column.php b/database/migrations/2024_06_20_142704_alter_nodes_add_swarm_id_column.php
new file mode 100644
index 0000000..10ba016
--- /dev/null
+++ b/database/migrations/2024_06_20_142704_alter_nodes_add_swarm_id_column.php
@@ -0,0 +1,28 @@
+<?php
+
+use Illuminate\Database\Migrations\Migration;
+use Illuminate\Database\Schema\Blueprint;
+use Illuminate\Support\Facades\Schema;
+
+return new class extends Migration
+{
+    /**
+     * Run the migrations.
+     */
+    public function up(): void
+    {
+        Schema::table('nodes', function (Blueprint $table) {
+            $table->foreignId('swarm_id')->nullable()->constrained('swarms')->nullOnDelete();
+        });
+    }
+
+    /**
+     * Reverse the migrations.
+     */
+    public function down(): void
+    {
+        Schema::table('nodes', function (Blueprint $table) {
+            $table->dropColumn('swarm_id');
+        });
+    }
+};
diff --git a/resources/js/Components/NodeTasks/TaskGroup.vue b/resources/js/Components/NodeTasks/TaskGroup.vue
new file mode 100644
index 0000000..9cbf3b6
--- /dev/null
+++ b/resources/js/Components/NodeTasks/TaskGroup.vue
@@ -0,0 +1,15 @@
+<script setup>
+import {reactive} from "vue";
+import TaskResult from "@/Components/NodeTasks/TaskResult.vue";
+
+defineProps({
+  'taskGroup': Object,
+});
+
+</script>
+
+<template>
+  <ul class="col-span-6 text-sm font-medium text-gray-900 bg-white border border-gray-200 rounded-lg dark:bg-gray-700 dark:border-gray-600 dark:text-white">
+    <TaskResult v-for="task in taskGroup.tasks" :key="task.id" :task="task" />
+  </ul>
+</template>
\ No newline at end of file
diff --git a/resources/js/Components/NodeTasks/TaskResult.vue b/resources/js/Components/NodeTasks/TaskResult.vue
new file mode 100644
index 0000000..4c2a25e
--- /dev/null
+++ b/resources/js/Components/NodeTasks/TaskResult.vue
@@ -0,0 +1,77 @@
+<script setup>
+import {computed, reactive} from "vue";
+
+const props = defineProps({
+  'task': Object,
+})
+
+const state = reactive({
+  expanded: props.task.status === 'failed',
+})
+
+const classes = computed(() => {
+  const modifier = props.task.status === 'failed' ? 'text-red-600 dark:text-red-500' : 'text-green-600 dark:text-green-500';
+
+  const base = 'px-4 py-2 flex items-center select-none ' + modifier;
+
+
+  if (props.task.result) {
+    return base + ' hover:cursor-pointer hover:bg-gray-50';
+  }
+
+  return base;
+})
+
+</script>
+
+<template>
+  <li
+      v-auto-animate="{duration: 100}"
+      class="w-full border-b border-gray-200 first:rounded-t-lg last:rounded-b-lg dark:border-gray-600 overflow-hidden">
+<div :class="classes"
+     @click="state.expanded = ! state.expanded && $props.task.result">
+    <svg
+        v-if="task.status === 'pending'"
+        class="w-4 h-4 me-2 text-gray-800 dark:text-white" aria-hidden="true" xmlns="http://www.w3.org/2000/svg" width="24" height="24" fill="none" viewBox="0 0 24 24">
+      <path stroke="currentColor" stroke-linecap="round" stroke-linejoin="round" stroke-width="2" d="M12 8v4l3 3m6-3a9 9 0 1 1-18 0 9 9 0 0 1 18 0Z"/>
+    </svg>
+
+    <svg
+        v-if="task.status === 'running'"
+        class="w-4 h-4 me-2 animate-rotate text-gray-800 dark:text-white" aria-hidden="true" xmlns="http://www.w3.org/2000/svg" width="24" height="24" fill="none" viewBox="0 0 24 24">
+      <path stroke="currentColor" stroke-linecap="round" stroke-linejoin="round" stroke-width="2" d="M17.651 7.65a7.131 7.131 0 0 0-12.68 3.15M18.001 4v4h-4m-7.652 8.35a7.13 7.13 0 0 0 12.68-3.15M6 20v-4h4"/>
+    </svg>
+
+  <svg
+      v-if="task.status === 'completed'"
+      class="w-4 h-4 me-2 text-green-600 dark:text-white" aria-hidden="true" xmlns="http://www.w3.org/2000/svg" width="24" height="24" fill="currentColor" viewBox="0 0 24 24">
+    <path fill-rule="evenodd" d="M2 12C2 6.477 6.477 2 12 2s10 4.477 10 10-4.477 10-10 10S2 17.523 2 12Zm13.707-1.293a1 1 0 0 0-1.414-1.414L11 12.586l-1.793-1.793a1 1 0 0 0-1.414 1.414l2.5 2.5a1 1 0 0 0 1.414 0l4-4Z" clip-rule="evenodd"/>
+  </svg>
+
+  <svg
+      v-if="task.status === 'failed'"
+      class="w-4 h-4 me-2 text-red-600 dark:text-white" aria-hidden="true" xmlns="http://www.w3.org/2000/svg" width="24" height="24" fill="currentColor" viewBox="0 0 24 24">
+    <path fill-rule="evenodd" d="M2 12C2 6.477 6.477 2 12 2s10 4.477 10 10-4.477 10-10 10S2 17.523 2 12Zm7.707-3.707a1 1 0 0 0-1.414 1.414L10.586 12l-2.293 2.293a1 1 0 1 0 1.414 1.414L12 13.414l2.293 2.293a1 1 0 0 0 1.414-1.414L13.414 12l2.293-2.293a1 1 0 0 0-1.414-1.414L12 10.586 9.707 8.293Z" clip-rule="evenodd"/>
+  </svg>
+
+
+
+
+  <span v-html="task.formatted_payload" class="grow" />
+
+    <span v-auto-animate="{duration: 100}" v-if="task.result">
+      <svg  v-if="state.expanded"
+            class="w-4 h-4 text-gray-800 dark:text-white" aria-hidden="true" xmlns="http://www.w3.org/2000/svg" width="24" height="24" fill="none" viewBox="0 0 24 24">
+  <path stroke="currentColor" stroke-linecap="round" stroke-linejoin="round" stroke-width="2" d="m16 14-4-4-4 4"/>
+</svg>
+    <svg
+        v-else
+        class="w-4 h-4 text-gray-800 dark:text-white" aria-hidden="true" xmlns="http://www.w3.org/2000/svg" width="24" height="24" fill="none" viewBox="0 0 24 24">
+      <path stroke="currentColor" stroke-linecap="round" stroke-linejoin="round" stroke-width="2" d="m8 10 4 4 4-4"/>
+    </svg>
+
+</span>
+</div>
+    <div v-if="state.expanded" class="px-4 py-2 border-t border-t-gray-100 bg-gray-50" v-html="task.formatted_result" />
+  </li>
+</template>
\ No newline at end of file
diff --git a/resources/js/Components/Select.vue b/resources/js/Components/Select.vue
index 8c8ab63..dd0ee21 100644
--- a/resources/js/Components/Select.vue
+++ b/resources/js/Components/Select.vue
@@ -1,13 +1,15 @@
 <script setup>
 import {defineProps} from 'vue';
 
+const model = defineModel();
+
 const props = defineProps({
-  'id': String,
+  'id': String
 })
 </script>
 
 <template>
-  <select :id="$props.id" class="bg-gray-50 border border-gray-300 text-gray-900 text-sm rounded-lg focus:ring-blue-500 focus:border-blue-500 block w-full p-2.5 dark:bg-gray-700 dark:border-gray-600 dark:placeholder-gray-400 dark:text-white dark:focus:ring-blue-500 dark:focus:border-blue-500">
+  <select :id="$props.id" v-model="model" class="bg-gray-50 border border-gray-300 text-gray-900 text-sm rounded-lg focus:ring-blue-500 focus:border-blue-500 block w-full p-2.5 dark:bg-gray-700 dark:border-gray-600 dark:placeholder-gray-400 dark:text-white dark:focus:ring-blue-500 dark:focus:border-blue-500">
     <slot />
   </select>
 </template>
\ No newline at end of file
diff --git a/resources/js/Pages/Nodes/Partials/InitSwarmProgress.vue b/resources/js/Pages/Nodes/Partials/InitSwarmProgress.vue
new file mode 100644
index 0000000..5653eb6
--- /dev/null
+++ b/resources/js/Pages/Nodes/Partials/InitSwarmProgress.vue
@@ -0,0 +1,25 @@
+<script setup>
+
+import ActionSection from "@/Components/ActionSection.vue";
+import TaskGroup from "@/Components/NodeTasks/TaskGroup.vue";
+
+defineProps({
+  'taskGroup': Object
+});
+</script>
+<template>
+  <ActionSection>
+
+    <template #title>
+      Swarm Cluster
+    </template>
+
+    <template #description>
+      Node is currently initializing the Swarm Cluster.
+    </template>
+
+    <template #content>
+      <TaskGroup :taskGroup="taskGroup"/>
+    </template>
+  </ActionSection>
+</template>
\ No newline at end of file
diff --git a/resources/js/Pages/Nodes/Partials/NewSwarmCluster.vue b/resources/js/Pages/Nodes/Partials/NewSwarmCluster.vue
index 7a7bdd1..a3e910f 100644
--- a/resources/js/Pages/Nodes/Partials/NewSwarmCluster.vue
+++ b/resources/js/Pages/Nodes/Partials/NewSwarmCluster.vue
@@ -1,5 +1,5 @@
 <script setup>
-import {defineProps} from "vue";
+import {defineProps, reactive} from "vue";
 import {router, useForm} from "@inertiajs/vue3";
 import PrimaryButton from "@/Components/PrimaryButton.vue";
 import FormSection from "@/Components/FormSection.vue";
@@ -7,7 +7,7 @@ import TextInput from "@/Components/TextInput.vue";
 import InputLabel from "@/Components/InputLabel.vue";
 import InputError from "@/Components/InputError.vue";
 import Dropdown from "@/Components/Dropdown.vue";
-import {FwbSelect} from "flowbite-vue";
+import {FwbCheckbox, FwbSelect} from "flowbite-vue";
 import Select from "@/Components/Select.vue";
 import FormField from "@/Components/FormField.vue";
 
@@ -15,19 +15,28 @@ const props = defineProps({
   node: Object
 });
 
-const form = useForm({
-  swarm_name: '',
-    swarm_option: 'init',
-    swarm_init: {
-        listen_addr: '',
+const swarmOption = reactive({
+  form: 'init',
+});
+
+const initForm = useForm({
+  node_id: props.node.id,
+  name: '',
         advertise_addr: '',
         force_new_cluster: false
-    }
 })
+
+const submit = () => {
+  // TODO: if option is 'init' -> initCluster()
+  // TODO: if option is 'join' -> joinCluster()
+  initForm.post(route('swarm-tasks.init-cluster'), {
+    preserveScroll: 'errors'
+  });
+}
 </script>
 
 <template>
-    <FormSection>
+    <FormSection @submitted="submit">
         <template #title>
             Swarm Cluster
         </template>
@@ -41,13 +50,13 @@ const form = useForm({
                 <ul class="items-center w-full text-sm font-medium text-gray-900 bg-white border border-gray-200 rounded-lg sm:flex dark:bg-gray-700 dark:border-gray-600 dark:text-white">
                     <li class="w-full border-b border-gray-200 sm:border-b-0 sm:border-r dark:border-gray-600">
                         <div class="flex items-center ps-3">
-                            <input id="swarm-init-option" v-model="form.swarm_option" type="radio" value="init" name="list-radio" class="w-4 h-4 text-blue-600 bg-gray-100 border-gray-300 focus:ring-blue-500 dark:focus:ring-blue-600 dark:ring-offset-gray-700 dark:focus:ring-offset-gray-700 focus:ring-2 dark:bg-gray-600 dark:border-gray-500">
+                            <input id="swarm-init-option" v-model="swarmOption.form" type="radio" value="init" name="list-radio" class="w-4 h-4 text-blue-600 bg-gray-100 border-gray-300 focus:ring-blue-500 dark:focus:ring-blue-600 dark:ring-offset-gray-700 dark:focus:ring-offset-gray-700 focus:ring-2 dark:bg-gray-600 dark:border-gray-500">
                             <label for="swarm-init-option" class="w-full py-3 ms-2 text-sm font-medium text-gray-900 dark:text-gray-300">Initialize Cluster</label>
                         </div>
                     </li>
                     <li class="w-full border-b border-gray-200 sm:border-b-0 sm:border-r dark:border-gray-600">
                         <div class="flex items-center ps-3">
-                            <input id="swarm-join-option" v-model="form.swarm_option" type="radio" value="join" name="list-radio" class="w-4 h-4 text-blue-600 bg-gray-100 border-gray-300 focus:ring-blue-500 dark:focus:ring-blue-600 dark:ring-offset-gray-700 dark:focus:ring-offset-gray-700 focus:ring-2 dark:bg-gray-600 dark:border-gray-500">
+                            <input id="swarm-join-option" v-model="swarmOption.form" type="radio" value="join" name="list-radio" class="w-4 h-4 text-blue-600 bg-gray-100 border-gray-300 focus:ring-blue-500 dark:focus:ring-blue-600 dark:ring-offset-gray-700 dark:focus:ring-offset-gray-700 focus:ring-2 dark:bg-gray-600 dark:border-gray-500">
                             <label for="swarm-join-option" class="w-full py-3 ms-2 text-sm font-medium text-gray-900 dark:text-gray-300">Join an Existing Cluster</label>
                         </div>
                     </li>
@@ -57,23 +66,26 @@ const form = useForm({
             </div>
 
           <div v-auto-animate class="col-span-6 sm:col-span-4">
-          <template v-if="form.swarm_option === 'init'">
+          <template v-if="swarmOption.form === 'init'">
             <template v-if="$props.node.data.host.networks.length > 0" >
               <FormField>
                 <InputLabel for="swarm_name" value="Swarm Name" />
-                <TextInput id="swarm_name" v-model="form.swarm_name" class="block w-full" />
-                <InputError :message="form.errors.swarm_name" class="mt-2" />
+                <TextInput id="swarm_name" v-model="initForm.name" class="block w-full" />
+                <InputError :message="initForm.errors.name" class="mt-2" />
               </FormField>
-
               <FormField>
-                <InputLabel for="listen_addr" value="Listen Address" />
-              <Select id="listen_addr" v-model="form.swarm_init.listen_addr">
-                <option>Select Listen Address</option>
+                <InputLabel for="advertise_addr" value="Advertisement Address" />
+              <Select id="advertise_addr" v-model="initForm.advertise_addr">
+                <option>Select Advertise Address</option>
                 <optgroup v-for="network in $props.node.data.host.networks" :label="network.if_name">
                   <option v-for="ip in network.ips" :value="ip.ip">{{ ip.ip }}</option>
                 </optgroup>
               </Select>
-                <InputError :message="form.errors.listen_addr" class="mt-2" />
+                <InputError :message="initForm.errors.advertise_addr" class="mt-2" />
+              </FormField>
+
+              <FormField>
+                <FwbCheckbox label="Force New Cluster" v-model="initForm.force_new_cluster" />
               </FormField>
             </template>
             <template v-else>
@@ -81,10 +93,10 @@ const form = useForm({
             </template>
           </template>
 
-          <div v-if="form.swarm_option === 'join'">
+          <div v-if="swarmOption.form === 'join'">
             Unfortunately, this feature is not implemented yet.
           </div>
-          </div v-auto-animate class="col-span-6 sm:col-span-4">
+          </div>
         </template>
 
 
diff --git a/resources/js/Pages/Nodes/Show.vue b/resources/js/Pages/Nodes/Show.vue
index 0385126..1ac2b06 100644
--- a/resources/js/Pages/Nodes/Show.vue
+++ b/resources/js/Pages/Nodes/Show.vue
@@ -11,10 +11,12 @@ import {onMounted, ref} from "vue";
 import AgentInstall from "@/Pages/Nodes/Partials/AgentInstall.vue";
 import AgentStatus from "@/Pages/Nodes/Partials/AgentStatus.vue";
 import SectionBorder from "@/Components/SectionBorder.vue";
+import InitSwarmProgress from "@/Pages/Nodes/Partials/InitSwarmProgress.vue";
 
 defineProps([
-    'node'
-])
+    'node',
+    'initTaskGroup',
+]);
 
 
 
@@ -30,6 +32,7 @@ defineProps([
 
       <SectionBorder v-if="$props.node.online" />
 
-        <NewSwarmCluster v-if="$props.node.online" :node="$props.node"/>
+        <NewSwarmCluster v-if="$props.node.online && $props.node.swarm_id === null" :node="$props.node"/>
+      <InitSwarmProgress v-if="$props.initTaskGroup" :taskGroup="$props.initTaskGroup" />
     </ShowLayout>
 </template>
diff --git a/routes/api.php b/routes/api.php
index 587c58b..017fab2 100644
--- a/routes/api.php
+++ b/routes/api.php
@@ -1,14 +1,22 @@
 <?php
 
+use ApiNodes\Http\Controllers\TaskController;
 use ApiNodes\Http\Controllers\EventController;
+use ApiNodes\Http\Controllers\NextTaskController;
 use ApiNodes\Http\Middleware\AgentTokenAuth;
 use Illuminate\Http\Request;
 use Illuminate\Support\Facades\Route;
 
-Route::group(['middleware' => AgentTokenAuth::class, 'prefix' => '/_nodes/v1'], function () {
+Route::prependMiddlewareToGroup('api', AgentTokenAuth::class)->group(['prefix' => '/_nodes/v1'], function () {
     Route::group(['prefix' => '/events'], function () {
         Route::post('/started', [EventController::class, 'started']);
     });
+
+    Route::group(['prefix' => '/tasks'], function () {
+        Route::get('/next', NextTaskController::class);
+        Route::post('/{task}/complete', [TaskController::class, 'complete']);
+        Route::post('/{task}/fail', [TaskController::class, 'fail']);
+    });
 });
 
 Route::get('/user', function (Request $request) {
diff --git a/routes/web.php b/routes/web.php
index 771f071..d8b22a8 100644
--- a/routes/web.php
+++ b/routes/web.php
@@ -1,5 +1,7 @@
 <?php
 
+use App\Http\Controllers\NodeController;
+use App\Http\Controllers\SwarmTaskController;
 use Illuminate\Foundation\Application;
 use Illuminate\Support\Facades\Route;
 use Inertia\Inertia;
@@ -22,5 +24,7 @@
         return Inertia::render('Dashboard');
     })->name('dashboard');
 
-    Route::resource("nodes", \App\Http\Controllers\NodeController::class);
+    Route::post('/swarm-tasks/init-cluster', [SwarmTaskController::class, 'initCluster'])->name('swarm-tasks.init-cluster');
+
+    Route::resource("nodes", NodeController::class);
 });
diff --git a/tailwind.config.js b/tailwind.config.js
index e8be2da..d195928 100644
--- a/tailwind.config.js
+++ b/tailwind.config.js
@@ -19,6 +19,15 @@ export default {
             fontFamily: {
                 sans: ['Figtree', ...defaultTheme.fontFamily.sans],
             },
+            keyframes: {
+                rotate: {
+                    '0%': { transform: 'rotate(0deg)' },
+                    '100%': { transform: 'rotate(360deg)' },
+                },
+            },
+            animation: {
+                rotate: 'rotate 2s linear infinite',
+            },
         },
     },