os.getenv("SUPABASE_URL"),
os.getenv("SUPABASE_KEY"),
options=ClientOptions(schema="pgmq_public")
)
message = {
'type': 'conversation_generation',
'email': user.user.email,
'model_instance_id': model_instance_response.data[0]['instance_id']
}
generation_task_response = supabase_queue_client.rpc('send', { 'queue_name': QUEUE_CONVERSATION_GENERATION, 'message': message}).execute()
if not generation_task_response.data:
return jsonify({'error': 'Error creating the generation task'}), 500
os.getenv("SUPABASE_URL"),
os.getenv("SUPABASE_KEY"),
options=ClientOptions(schema="pgmq_public")
)
message = {
'type': 'conversation_generation',
'email': user.user.email,
'model_instance_id': model_instance_response.data[0]['instance_id']
}
generation_task_response = supabase_queue_client.rpc('send', { 'queue_name': QUEUE_CONVERSATION_GENERATION, 'message': message}).execute()
if not generation_task_response.data:
return jsonify({'error': 'Error creating the generation task'}), 500