Untitled

import os
from openai import OpenAI
from dotenv import load_dotenv, find_dotenv
import prompts
import time  # Add this import statement

# assistant idsi :   asst_44OtUDJMGO0PmhkzzoMJuSn4

# Load environment variables from .env file
load_dotenv(find_dotenv())

client = OpenAI(
    api_key=os.environ.get("OPENAI_API_KEY")
)

thread = client.beta.threads.create()

message = client.beta.threads.messages.create(
    thread_id=thread.id,
    role="user",
    content="""
    İl	Muğla 
    İlçe	Menteşe 
    Mahalle/Köy	Zeytinköy 
    Mahalle No	138550 
    Ada	366 
    Parsel	18 
    Tapu Alanı	744,24 
    Nitelik	Tarla 
    -----------------------------------------------------------------------------------------------------------------------------
    37.0623 , 28.0669
    -----------------------------------------------------------------------------------------------------------------------------
    Akbük koyu 5km
    -----------------------------------------------------------------------------------------------------------------------------
    Fotograflar Var 
    Görüntülerde yan taraftaki villanın ve denizin vurgulanmasını istiyoruz
    -----------------------------------------------------------------------------------------------------------------------------
    Kayalı mevkii
    Akbük zeytinköy anayoluna cephe
    Hemen önünde suyu kuyusu var
    Bir kaç parsel yan tarafında taş villada yaşam var 
    Örene 15 km
    Köyde market cami sağlık ocağına bir kaç kilometrede
    Deniz,doğa ve kanyon manzaralı 
    Sessiz sakin bir yer
    Telefon numarası olarak 05050489292 """ ,
)




##################################################################

run = client.beta.threads.runs.create(
    thread_id=thread.id,
    assistant_id="asst_44OtUDJMGO0PmhkzzoMJuSn4",
)



# Polling loop to check the run status
while True:
    run = client.beta.threads.runs.retrieve(
        thread_id=thread.id,
        run_id=run.id,
    )
    
    # Break the loop if the run is completed
    if run.status == "completed":
        print("Run completed successfully.")
        break
    
    # If the run is still in progress, wait a bit and check again
    if run.status == "in_progress":
        print("Run still in progress, waiting...")
        time.sleep(2)  # Wait for 2 seconds before checking again
    
    # Check if the run failed
    if run.status == "failed":
        print("Run failed.")
        break


# List all messages in the thread
messages = client.beta.threads.messages.list(
    thread_id=thread.id
)

# Print out the messages
for message in reversed(messages.data):
    if message.content:
        for i, content in enumerate(message.content):
            print(f"{message.role}: {content.text.value}")
    else:
        print(f"{message.role}: No content found")