Run anything.
Know instantly. Stay anywhere.

from slackker.core import TelegramClient
from slackker.callbacks.keras import KerasCallback

client = TelegramClient(
    token="123456:ABC-DEF...",
    verbose=1
)
slackker_cb = KerasCallback(
    client=client,
    model_name="ImageClassifierV1",
    export="png",
    send_plot=True,
)

history = model.fit(
    x_train,
    y_train,
    epochs=20,
    batch_size=32,
    validation_data=(x_val, y_val),
    callbacks=[slackker_cb]
)

from lightning.pytorch import Trainer
from slackker.core import TelegramClient
from slackker.callbacks.lightning import LightningCallback

client = TelegramClient(
    token="123456:ABC-DEF...",
    verbose=1
)

class LightningModel(LightningModule):
    def training_step(self, batch, batch_idx):
        x, y = batch
        y_hat = self.forward(x)
        loss = F.cross_entropy(y_hat, y)
        accuracy = (torch.max(y_hat, 1)[1] == y).float().mean()
        # log with on_epoch=True so slackker can read them at epoch end
        self.log("train_loss", loss, on_epoch=True)
        self.log("train_acc", accuracy, on_epoch=True)
        return loss

    def validation_step(self, batch, batch_idx):
        x, y = batch
        y_hat = self.forward(x)
        loss = F.cross_entropy(y_hat, y)
        accuracy = (torch.max(y_hat, 1)[1] == y).float().mean()
        # log with on_epoch=True so slackker can read them at epoch end
        self.log("val_loss", loss, on_epoch=True)
        self.log("val_acc", accuracy, on_epoch=True)
        return loss

model = LightningModel()

slackker_cb = LightningCallback(
    client=client,
    model_name="LightningClassifier",
    track_logs=["train_loss", "train_acc", "val_loss", "val_acc"],
    monitor="val_loss",
    export="png",
    send_plot=True,
)

trainer = Trainer(max_epochs=12, callbacks=[slackker_cb])
trainer.fit(model, train_loader, val_loader)

import time
from slackker.core import TelegramClient
from slackker.callbacks.simple import SimpleCallback

client = TelegramClient(
    token="123456:ABC-DEF...",
    verbose=1
)
notifier = SimpleCallback(client)

def main():
    # Step 1
    notifier.notify("📥 Step 1: Fetching data...", status="started")
    time.sleep(2)
    if not notifier.ask("Step 1 done. Continue?"):
        notifier.stop()
        return
    notifier.notify("✅ Step 1: Data fetched", status="completed")

    # Step 2
    notifier.notify("⚙️ Step 2: Processing data...", status="started")
    time.sleep(2)
    if not notifier.ask("Step 2 done. Continue?"):
        notifier.stop()
        return
    notifier.notify("✅ Step 2: Processing done", status="completed")

    # Done
    notifier.notify(
        "🏁 Pipeline complete",
        message="All steps finished ✅",
        attachment="./report.pdf"
    )
    notifier.stop()

main()