Если ты решился расти с 1–2 нод до целого кластера - держи короткий гайд, как не утопить Redis и не ловить OOM-ы.
Включи celery events и следи за:
redis-cli --latency) - держи p95 < 10–20 мс.Чтобы понять, где предел, сделай три типа задач:
Поднимай concurrency по шагам - смотри, где падает throughput или растёт latency.
Идеал - максимум задач без лагов и OOM.
Обычно выходит 0.5–0.7 × число ядер.
per_worker_conc = cores × коэффициент
cluster_conc = per_worker_conc × 16
RAM ≈ per_task_RSS × per_worker_conc × 1.3
#airflow #celery #redis #config #ha #cluster
Please open Telegram to view this post
VIEW IN TELEGRAM
1 8 4
Forwarded from Технозаметки Малышева
Agents 2.0: от примитивных циклов к глубокомыслящим агентам
Год назад ИИ-агент был простым while-циклом: промпт → LLM → инструмент → повтор. Решало обычные быстрые задачи типа "какая погода в Токио", но на задачах в 50 шагов, который могут выполняться несколько дней агент терялся, зацикливался, галлюцинировал.
Сейчас архитектура меняется. Deep Agents не просто реагируют, они планируют, делегируют работу специализированным саб-агентам и хранят память вне контекста.
В заметке выделяется четыре ключевые составляющие:
- Явное детальное планирование через цепочку размышлений с сохранением в markdown to-do с отслеживанием прогресса
- Иерархическая оркестрация с распределенением задач между узкими специалистами под-агентами (researcher, coder, writer) и именно они уже вызывают инструменты. Оркестратору возвращается только резальтат
- Внешняя память в файловой системе или векторных БД вместо переполненного контекста. Причём часть под-агентов могут только писать в память, а часть - только читать!
- Промпты на тысячи токенов с детальными инструкциями и указанием структур доступных инструментов и когда стоит подключить человека.
Интересное краткое отражение факта эволюции развития агентских систем.
Полезно и для понимания архитектуры и для презентаций.
#DeepAgents #Orchestrator #SubAgents
———
@tsingular
Год назад ИИ-агент был простым while-циклом: промпт → LLM → инструмент → повтор. Решало обычные быстрые задачи типа "какая погода в Токио", но на задачах в 50 шагов, который могут выполняться несколько дней агент терялся, зацикливался, галлюцинировал.
Сейчас архитектура меняется. Deep Agents не просто реагируют, они планируют, делегируют работу специализированным саб-агентам и хранят память вне контекста.
В заметке выделяется четыре ключевые составляющие:
- Явное детальное планирование через цепочку размышлений с сохранением в markdown to-do с отслеживанием прогресса
- Иерархическая оркестрация с распределенением задач между узкими специалистами под-агентами (researcher, coder, writer) и именно они уже вызывают инструменты. Оркестратору возвращается только резальтат
- Внешняя память в файловой системе или векторных БД вместо переполненного контекста. Причём часть под-агентов могут только писать в память, а часть - только читать!
- Промпты на тысячи токенов с детальными инструкциями и указанием структур доступных инструментов и когда стоит подключить человека.
Интересное краткое отражение факта эволюции развития агентских систем.
Полезно и для понимания архитектуры и для презентаций.
#DeepAgents #Orchestrator #SubAgents
———
@tsingular
Forwarded from Время Валеры
На днях в open source выпустили распределённую файловую систему, которая рассчитана на эксабайты (тысячи петабайт).
Сделали это чуваки из XTX, мощные трейдеры, которые известны двумя вещами: тем, что у них (по крайней мере недавно) был топ-3 кластер по количеству ГПУ, и тем, что их основатель, Александр Герко, так любит Лондон, что каждый год платит 500+ млн фунтов налогов на доходы как физическое лицо.
Из интересного (они выделили 9 пунктов, но только 5 мне кажутся отличительными)
Has no single point of failure in its metadata services.
Is hardware agnostic and uses TCP/IP to communicate.
Utilizes different types of storage (such as flash vs. hard disks) cost effectively.
Exposes read/write access through its own API over TCP and UDP, and a Linux kernel filesystem module.
Requires no external service and has a minimal set of build dependencies
Начали работы над системой в 2022 году, в середине 2024 мигрировали весь ML
TernFS' metadata is split into 256 logical shards. Shards never communicate with each other. This is a general principle in TernFS: Splitting the metadata into 256 shards from the get-go simplifies the design, given that horizontal scaling of metadata requires no rebalancing, just the addition of more metadata servers.
Ну и заодно свой формат сериализации разработали, чтобы разработчики передвигали не json, thrift, а что-то там свое.
Еще из интересного - обсуждение когда нужно зеркалить файлы, а когда делать Reed-Solomon coding.
Рекомендую почитать
Сделали это чуваки из XTX, мощные трейдеры, которые известны двумя вещами: тем, что у них (по крайней мере недавно) был топ-3 кластер по количеству ГПУ, и тем, что их основатель, Александр Герко, так любит Лондон, что каждый год платит 500+ млн фунтов налогов на доходы как физическое лицо.
Из интересного (они выделили 9 пунктов, но только 5 мне кажутся отличительными)
Has no single point of failure in its metadata services.
Is hardware agnostic and uses TCP/IP to communicate.
Utilizes different types of storage (such as flash vs. hard disks) cost effectively.
Exposes read/write access through its own API over TCP and UDP, and a Linux kernel filesystem module.
Requires no external service and has a minimal set of build dependencies
Начали работы над системой в 2022 году, в середине 2024 мигрировали весь ML
TernFS' metadata is split into 256 logical shards. Shards never communicate with each other. This is a general principle in TernFS: Splitting the metadata into 256 shards from the get-go simplifies the design, given that horizontal scaling of metadata requires no rebalancing, just the addition of more metadata servers.
Ну и заодно свой формат сериализации разработали, чтобы разработчики передвигали не json, thrift, а что-то там свое.
Еще из интересного - обсуждение когда нужно зеркалить файлы, а когда делать Reed-Solomon coding.
Рекомендую почитать
Xtxmarkets
TernFS: an exabyte scale, multi-region distributed filesystem | XTX Tech Blog
XTX Markets is a leading algorithmic trading firm which uses state-of-the-art machine learning technology to produce price forecasts for over 50,000 financial instruments across equities, fixed income, currencies, commodities and crypto. It uses those forecasts…
❤🔥6 2
Forwarded from DataEng
The Annual Airflow Survey
Если вы пользуетесь Apache Airflow, то давайте поможем сообществу собрать больше информации об использовании Airflow. До 20 ноября необходимо заполнить опросник на сайте взамен вы получите возможность пройти сертификацию по Airflow от Astronomer бесплатно (я сдавал их экзамен и он хороший). Опросник небольшой, замёт не более 10 минут вашего времени.
Если вы пользуетесь Apache Airflow, то давайте поможем сообществу собрать больше информации об использовании Airflow. До 20 ноября необходимо заполнить опросник на сайте взамен вы получите возможность пройти сертификацию по Airflow от Astronomer бесплатно (я сдавал их экзамен и он хороший). Опросник небольшой, замёт не более 10 минут вашего времени.
Typeform
Apache Airflow® Survey 2025
Share your feedback to help shape the future of Airflow and improve its day-to-day use.
Время Валеры
На днях в open source выпустили распределённую файловую систему, которая рассчитана на эксабайты (тысячи петабайт). Сделали это чуваки из XTX, мощные трейдеры, которые известны двумя вещами: тем, что у них (по крайней мере недавно) был топ-3 кластер по количеству…
Новая ФС от алготрейдеров? Почему бы и нет. Говорят, каждый большой техно-бизнес рано или поздно пишет свою файловую систему - вот и XTX Markets не стали исключением. Они выкатили в open source собственную распределённую FS под названием TernFS. Эта система способна переваривать эксабайты данных и рассчитана на миллионы файлов и высокопараллельные нагрузки - то, что надо для их ML-ферм, где обычные NFS/Ceph уже не вывозят.
▶️ Конечно, чудес не бывает. TernFS не любит совсем мелкие файлы (<2 МБ) и не рассчитана на бесконечное создание миллионов отдельных каталогов. Файлы в ней только дописываются, но не изменяются после факта (immutable-дизайн). Своей системы разрешений/аутентификации нет - этим должен заниматься внешний уровень. Проще говоря, TernFS хороша для больших объёмов статичных данных (логов, моделей, бэкапов, результатов расчётов и пр.), но не годится как замена обычной FS в сценариях с частыми правками и мелочью.
▶️ ▶️ Вывод: XTX проделали тот же трюк, что и Google с Facebook - создали свою распределённую ФС под специфичные задачи, но внезапно поделились ею с миром. Репозиторий открыт (GPLv2) на GitHub - xtxmarkets/ternfs. Так что если однажды придётся укрощать эксабайты данных или просто хочешь разобраться, как устроена современная файловая система такого масштаба 6 почему бы не заглянуть? Всё-таки не каждый день финансисты выкатывают в open source технологии на уровне топовых IT-грандов 😉 .
#fs #algotrading #trading #de
#fs #algotrading #trading #de
Please open Telegram to view this post
VIEW IN TELEGRAM
Forwarded from DataEng
Ребята из Qdrant запустили бесплатный семидневный курс про свою векторную базу данных: Qdrant Essentials
Меня в последнее время интересует тема векторного поиска и векторных БД, и Qdrant как раз неплохой кандидат на изучение и реализацию какого-нибудь проекта (спойлер:домашнего векторного поисковика ). Курс прям как по заказу!
Меня в последнее время интересует тема векторного поиска и векторных БД, и Qdrant как раз неплохой кандидат на изучение и реализацию какого-нибудь проекта (спойлер:
qdrant.tech
Qdrant Essentials Course - Qdrant
Learn hybrid search, multivectors, and production deployment in 7 days. Build and ship a docs search engine.
❤🔥6😁1
Lakehouse 1.0 vs 2.0
🚀 Lakehouse 1.0 - попытка починить склад
Первая версия Lakehouse решала боль Data Warehouse, но делала это по-старому:
💾 Закрытая логика: Метрики и схемы жили в силосах BI-систем. Любая миграция - боль.
🔄 Одна сущность - три версии правды: Отчёт маркетинга ≠ отчёт продаж ≠ отчёт ops.
⚙️ Тесно связанные компоненты: compute + storage = монолит.
🔒 Vendor lock: Форматы, метаданные, даже governance принадлежали платформе-вендору.
🧩 Нет нативной семантики: Каждый инструмент крутил свои метрики вручную.
Результат - дорого, фрагментированно и очень трудно масштабировать без потери доверия к данным.
〰️ 〰️ 〰️ 〰️ 〰️ 〰️ 〰️ 〰️ 〰️ 〰️ 〰️ 〰️ 〰️
🏄♂️ Lakehouse 2.0 - построить систему, как работают команды
Второе поколение решает ключевую проблему - делает данные живыми, гибкими и нативными для разных стеков:
🧠 Semantic / Metrics Layer: Единый слой правды. Метрики, онтологии и контракты данных живут вместе.
🌐 Децентрализованные операции: Каждая команда (Sales, Mkt, Ops) может обновлять общую истину через свои доменные API.
🧩 Composable Compute: Можно выбирать движок: Spark, Trino, Dremio - без зависимости от формата.
🪶 Open Formats & Metadata: Никаких "запертых" схем. Метаданные - общие, интероперабельные.
🗂️ Catalog beyond data: Каталог объединяет логику, политику, lineage и ресурсы - мультиинструментальная, не моновендорная экосистема.
Lakehouse 1.0 - это инфраструктура.
Lakehouse 2.0 - это культура данных.
#de #dwh #lakehouse
Первая версия Lakehouse решала боль Data Warehouse, но делала это по-старому:
⚙️ Тесно связанные компоненты: compute + storage = монолит.
🧩 Нет нативной семантики: Каждый инструмент крутил свои метрики вручную.
Результат - дорого, фрагментированно и очень трудно масштабировать без потери доверия к данным.
Второе поколение решает ключевую проблему - делает данные живыми, гибкими и нативными для разных стеков:
🧩 Composable Compute: Можно выбирать движок: Spark, Trino, Dremio - без зависимости от формата.
🪶 Open Formats & Metadata: Никаких "запертых" схем. Метаданные - общие, интероперабельные.
🗂️ Catalog beyond data: Каталог объединяет логику, политику, lineage и ресурсы - мультиинструментальная, не моновендорная экосистема.
Lakehouse 1.0 - это инфраструктура.
Lakehouse 2.0 - это культура данных.
#de #dwh #lakehouse
Please open Telegram to view this post
VIEW IN TELEGRAM
🤖 Робот по цене смартфона 🙂
Китайский стартап Noetix Robotics показал гуманоида Bumi за ¥9 998 (~$1.4k).
Детский рост 94 см, вес ~12 кг. Умеет ходить/бегать/танцевать, понимает голос и поддерживает блочное программирование для учебы и игр.
Предзаказ уже открыт в Китае (JD и оф. каналы) в окне 23.10🔜 12.12.
Цена смартфона за домашнего гуманоида - потребительский сегмент реально стартовал.
#Bumi #Noetix #robotics #гуманоиды #роботы
Китайский стартап Noetix Robotics показал гуманоида Bumi за ¥9 998 (~$1.4k).
Детский рост 94 см, вес ~12 кг. Умеет ходить/бегать/танцевать, понимает голос и поддерживает блочное программирование для учебы и игр.
Предзаказ уже открыт в Китае (JD и оф. каналы) в окне 23.10
Цена смартфона за домашнего гуманоида - потребительский сегмент реально стартовал.
#Bumi #Noetix #robotics #гуманоиды #роботы
Please open Telegram to view this post
VIEW IN TELEGRAM
1 7
Forwarded from FastNews | Никита Пастухов
Если вы вдруг не знаете, как оплатить подписку на OpenAI из РФ, то хочу вам прорекламировать отличный сервис - поисковик Github!🚀
Пара тысяч совершенно бесплатных ключей от вайбкодеров ждет вас🌚
https://github.com/search?q=OPENAI_API_KEY%3D%22&type=code
Пара тысяч совершенно бесплатных ключей от вайбкодеров ждет вас🌚
https://github.com/search?q=OPENAI_API_KEY%3D%22&type=code
Please open Telegram to view this post
VIEW IN TELEGRAM
😁19❤🔥2
Самая частая уязвимость в AI-агентах - не хакинг, а обычный лог.
Промпт, трейсбек, tool-вызов - всё это может случайно засветить токен или пароль.
Обычно утечка выглядит так:
print() в проде.sk-1234****abcd.Ни больше, ни меньше.
print() - потенциальный инцидент.#AI #AgentSecurity #AIAgents #CyberSecurity #DevSecOps #PromptEngineering #DataLeak #AIDev #Security #MLOps #LLM #OpenSource #TechSafety #AIпрактика #Инфобез #AIутечки #БЯМ
Please open Telegram to view this post
VIEW IN TELEGRAM
2❤🔥7😁2
DE
Санитайзер для гигиены секретов:
#code #py #helper #AIsecurity
import logging, os, re
SECRET_PATTERNS = [re.compile(r'(sk-[A-Za-z0-9]{10,})'),
re.compile(r'(?i)api[_-]?key\s*=\s*([A-Za-z0-9\-_.]+)')]
def sanitize(s: str) -> str:
if not s:
return s
for p in SECRET_PATTERNS:
s = p.sub(lambda m: m.group(0)[:4] + '****' + m.group(0)[-4:], s)
return s
class RedactingFormatter(logging.Formatter):
def format(self, record):
record.msg = sanitize(str(record.msg))
if record.args:
record.args = tuple(sanitize(str(a)) for a in record.args)
return super().format(record)
logger = logging.getLogger("agent")
logger.setLevel(logging.INFO) # не DEBUG
h = logging.StreamHandler()
h.setFormatter(RedactingFormatter("%(levelname)s %(message)s"))
logger.addHandler(h)
#code #py #helper #AIsecurity
3👏6 3❤🔥1😁1
Openai
Introducing ChatGPT Atlas
The browser with ChatGPT built in.
Что умеет Atlas
#Atlas #OpenAI #ChatGPT #AI #LLM #AIAgent #agents #ИИ #БЯМ #агенты
Please open Telegram to view this post
VIEW IN TELEGRAM
Внезапная новость: по результатам обсуждений разработчиков Apache Airflow решено отменить выпуск версии 3.1.1 RC1 и вместо него подготовить RC2.
Что произошло
🟢 23 октября 2025 года в рассылке разработчиков проекта был опубликован заголовок
🟢 Причина: связанная с выпуском ошибка зарегистрирована в GitHub‑issue #57145.
🟢 В письме указано, что голосование отменяется до устранения проблемы - после чего будет подготовлен релиз‑кандидат RC2.
Почему важно
🟡 Если ты планировал переход на Airflow 3.1.1 - стоит отложить обновление до выхода стабильного варианта после RC2.
🟡 Это демонстрирует, что команда проекта работает ответственно: пока ключевой баг не закрыт - релиз не будет утверждён.
#airflow #bug #release #de #dev
Что произошло
"[CANCELLED][VOTE] Release Airflow 3.1.1 from RC1". Почему важно
#airflow #bug #release #de #dev
Please open Telegram to view this post
VIEW IN TELEGRAM
DE
Внезапная новость: по результатам обсуждений разработчиков Apache Airflow решено отменить выпуск версии 3.1.1 RC1 и вместо него подготовить RC2. Что произошло 🟢 23 октября 2025 года в рассылке разработчиков проекта был опубликован заголовок "[CANCELLED][VOTE]…
Maintenance‑релиз поверх 3.1: "Significant changes" нет, зато много стабильности и UX‑правок. Если ты уже на 3.1.0 - апдейт пройдёт без сюрпризов.
retry_delay=None).max_retry_delay, dag_run.conf=None, пр.). Полный список в релиз‑ноутах. И да, рядом поехал и Task SDK 1.1.1 - если выносишь таски за пределы core‑рантайма, это тоже к обновлению.
#airflow #de #data #dataengineering
Please open Telegram to view this post
VIEW IN TELEGRAM
Авиакомпания планирует закупить до 100 машин, начиная с гос-применений (экстренные службы, инфраструктура) и далее - пассажирские перевозки.
Midnight рассчитан на пилота + 4 пассажиров, полёт 10–20 мин заменяет часовую поездку по земле.
#future #cars #drones #drone #aerotaxi #аэротакси #дроны
Please open Telegram to view this post
VIEW IN TELEGRAM
❤🔥5 2👏1