pavlovmilen’s gists

pavlovmilen / kubernetes.yaml

Last active July 27, 2025 11:52

Kubernetes yaml files

pavlovmilen / jaeger_service.py

Created July 27, 2025 11:48

Jaeger Service

	import subprocess
	import time
	import socket
	import logging
	import os

	logger = logging.getLogger(__name__)

	class JaegerService:
	"""Manages local Jaeger container for development"""

pavlovmilen / shared_tracing.py

Created July 27, 2025 11:46

Shared tracing code

	"""
	Shared tracing utilities for AutoGen agent teams.
	Provides common OpenTelemetry setup and helper functions to avoid code duplication.
	"""

	import os
	import logging

	try:
	from opentelemetry import trace

pavlovmilen / agents_with_mcp.py

Created July 15, 2025 18:26

agents_with_mcp

	# model client
	def get_fresh_model_client():
	"""Create a fresh Azure OpenAI client"""
	return AzureOpenAIChatCompletionClient(
	model=AZURE_OPENAI_MODEL,
	api_version=AZURE_OPENAI_API_VERSION,
	azure_deployment=AZURE_OPENAI_DEPLOYMENT,
	azure_endpoint=AZURE_OPENAI_ENDPOINT_SWEDEN,
	api_key=AZURE_OPENAI_API_KEY_SWEDEN,
	timeout=180.0,

pavlovmilen / OpenAIAssistantAgent_example.py

Created May 17, 2025 11:02

	az_client = AsyncOpenAI(
	api_key=os.environ.get("AZURE_OPEN_AI_API_KEY_SWEDEN"), # Use your OpenAI API key
	base_url=os.environ.get("AZURE_OPEN_AI_API_ENDPOINT_SWEDEN"),
	)

	gpt_model_client = AzureOpenAIChatCompletionClient(
	model="gpt-4.1-mini-2025-04-14",
	api_version="2024-06-01",
	azure_deployment="gpt-4.1-mini",
	azure_endpoint=os.environ.get("AZURE_OPEN_AI_API_ENDPOINT_SWEDEN"),

pavlovmilen / upload_ai_report.py

Created May 13, 2025 08:20

upload_ai_report function

	import os
	from azure.storage.blob import BlobServiceClient
	from datetime import datetime
	from dotenv import load_dotenv

	load_dotenv()
	connection_string = os.getenv('storage_connection_string')

	def upload_ai_report(report_summary: str, ticker: str):
	"""

pavlovmilen / complete_example.py

Created May 11, 2025 10:44

complete_example.py

	import os
	import sys

	from dotenv import load_dotenv

	from autogen_agentchat.agents import AssistantAgent
	from autogen_agentchat.base import TaskResult
	from autogen_agentchat.conditions import MaxMessageTermination, TextMentionTermination
	from autogen_agentchat.messages import BaseChatMessage
	from autogen_agentchat.teams import SelectorGroupChat

pavlovmilen / market_research_team_run.py

Created May 11, 2025 10:38

market_research_team_run

	runtime = SingleThreadedAgentRuntime()
	runtime.start()
	message_count = 0
	total_prompt_tokens = 0
	total_completion_tokens = 0

	async for message in market_reserarch_agents_team.run_stream(task="Hello, I would like to know if a stock with ticker=MSFT is a good pick for me to invest in this year?"):

	if isinstance(message, TaskResult):
	print("Stop Reason:", message.stop_reason)

pavlovmilen / gpt_model_client.py

Created May 11, 2025 10:35

gpt_model_client

	gpt_model_client = AzureOpenAIChatCompletionClient(
	model="gpt-4.1-mini-2025-04-14",
	api_version="2024-06-01",
	azure_deployment="gpt-4.1-mini",
	azure_endpoint=os.environ.get("AZURE_OPEN_AI_API_ENDPOINT_SWEDEN"),
	#azure_ad_token_provider=token_provider, # Optional if you choose key-based authentication.
	api_key=os.environ.get("AZURE_OPEN_AI_API_KEY_SWEDEN"),
	)

pavlovmilen / market_reserarch_agents_team.py

Created May 11, 2025 10:33

market_reserarch_agents_team

	market_reserarch_agents_team = SelectorGroupChat(
	[planning_agent, doji_agent, alpha_vantage_news_sentiment_agent, alpha_vantage_company_info_agent, fomc_summary_fetch_agent, peer_valuation_modeling_agent, report_generator_agent, report_upload_agent],
	termination_condition=termination,
	allow_repeated_speaker=True,
	model_client=gpt_model_client,
	selector_prompt=selector_prompt)

Milen Pavlov pavlovmilen