Upload 7 files

Dockerfile

@@ -0,0 +1,12 @@
+FROM python:3.11
+# FROM python:3.11-slim-bullseye
+
+WORKDIR /code
+
+COPY ./requirements.txt /code/requirements.txt
+
+RUN pip install --no-cache-dir --upgrade -r /code/requirements.txt
+
+COPY . ./
+
+CMD ["fastapi", "run", "endpoints.py", "--port", "8080"]

README.md

@@ -0,0 +1,29 @@
+---
+title: AI Workflows
+app_file: ui_main.py
+sdk: streamlit
+sdk_version: 1.35.0
+pinned: false
+python_version: 3.11.0
+---
+
+### Initial Setup
+* Install python using conda by running the following command. `conda create -p venv python==3.11 -y`
+* Activate conda profile `conda activate ./venv`
+* Install required packages `./venv/bin/pip install -r requirements.txt`
+* Copy .env.example to .env and enter the required values.
+*
+
+### Release process
+##### API server
+* Install flyctl by following instructions mentioned here https://fly.io/docs/flyctl/install/
+* Run `fly deploy` to deploy the app.
+
+
+##### Streamlit UI
+* Push code to main branch on huggingspace https://huggingface.co/spaces/beautiful-code/ai_workflows
+
+
+### Running on local
+* Streamlit app `streamlit run ui_main.py`
+* FastAPI app `uvicorn endpoints:app --port=8080`

endpoints.py

@@ -0,0 +1,74 @@
+from dotenv import load_dotenv
+import uvicorn
+from fastapi import FastAPI, Query
+from crew import til
+from fastapi.middleware.cors import CORSMiddleware
+from langsmith import Client
+from typing import List, Optional
+from pydantic import UUID4, BaseModel
+load_dotenv()
+
+description = """
+ API helps you do awesome stuff. 🚀
+
+"""
+
+tags_metadata = [
+    {
+        "name": "til_feedback",
+        "description": "Gives the feedback on user's TIL content",
+    },
+]
+
+app = FastAPI(
+    title="Growthy AI Worflows",
+    description=description,
+    summary="Deadpool's favorite app. Nuff said.",
+    version="0.0.1",
+    openapi_tags=tags_metadata,
+    docs_url="/documentation",
+)
+
+app.add_middleware(
+    CORSMiddleware,
+    allow_origins=["*"],
+    allow_credentials=True,
+    allow_methods=["*"],
+    allow_headers=["*"],
+)
+
+@app.post("/til_feedback", tags=["til_feedback"])
+async def til_feedback_kickoff(content: List[str]) -> til.TilFeedbackResponse:
+    separator = "\n* "
+    content[0] = "* " + content[0]
+    inputs = {"content": separator.join(content)}
+    result = til.TilCrew().kickoff(inputs)
+    return result
+
+class Feedback(BaseModel):
+    helpful_score: Optional[float]
+    feedback_on: Optional[str]
+
+@app.post("/til_feedback/{run_id}/feedback", tags=["til_feedback"])
+async def capture_feedback(run_id: UUID4, feedback: Feedback) -> str:
+    print("Helful Score: ", feedback.helpful_score)
+    print("Feedback On: ", feedback.feedback_on)
+    client = Client()
+    client.create_feedback(
+        str(run_id),
+        key="helpful",
+        score=feedback.helpful_score,
+        source_info={"til": feedback.feedback_on},
+        type="api",
+    )
+    return "ok"
+
+@app.get("/healthcheck")
+async def read_root():
+     return {"status": "ok"}
+
+
+if __name__ == "__main__":
+    uvicorn.run(app, host="127.0.0.1", port=8080)
+
+

fly.toml

@@ -0,0 +1,17 @@
+# fly.toml app configuration file generated for growthy-workflows on 2024-06-28T08:59:43+05:30
+#
+# See https://fly.io/docs/reference/configuration/ for information about how to use this file.
+#
+
+app = "growthy-workflows"
+primary_region = "sin"
+
+[build]
+
+[http_service]
+  internal_port = 8080
+  force_https = true
+  auto_stop_machines = true
+  auto_start_machines = true
+  min_machines_running = 0
+  processes = ["app"]

requirements.txt

@@ -0,0 +1,16 @@
+python-dotenv
+crewai
+crewai_tools
+langchain_community
+langchain_google_genai
+langchain_openai
+streamlit
+tavily-python
+arxiv
+semanticscholar
+streamlit-extras
+fastapi
+uvicorn
+fastapi_cors
+langsmith
+pytest

ui_main.py

@@ -0,0 +1,93 @@
+import streamlit as st
+from dotenv import load_dotenv
+from streamlit_extras.stylable_container import stylable_container
+from PIL import Image
+from ui.article_recommendation import main as article_recommendor_main
+from ui.research_paper import main as research_article_suggester_main
+from ui.til_feedback import main as feedback_main
+
+load_dotenv()
+
+
+st.set_page_config(page_title='Multi-Page App', page_icon='📰', layout='wide')
+
+def load_css(file_name):
+    with open(file_name) as f:
+        return f.read()
+
+def main():
+
+    if 'page' not in st.session_state:
+        st.session_state.page = "main"
+
+    if st.session_state.page == "main":
+        show_main_page()
+    elif st.session_state.page == "article_recommendor":
+        article_recommendor_main()
+    elif st.session_state.page == "research_article_suggester":
+        research_article_suggester_main()
+    elif st.session_state.page == "feedback":
+        feedback_main()
+
+def show_main_page():
+
+    css = load_css("ui/main.css")
+    st.markdown(f"<style>{css}</style>", unsafe_allow_html=True)
+
+    st.markdown('<div class="main-title">Welcome to the Multi-Page App!</div>', unsafe_allow_html=True)
+    st.markdown("---")
+    st.markdown('<div class="sub-header">Navigate to Specific Pages:</div>', unsafe_allow_html=True)
+
+    card_info = [
+        {"title": "Article Recommendor", "description": "Discover articles tailored to your interests.", "key": "article_recommendor"},
+        {"title": "Recent Article Suggester", "description": "Get suggestions for recent research articles.", "key": "research_article_suggester"},
+        {"title": "Feedback", "description": "Provide your valuable feedback.", "key": "feedback"},
+    ]
+
+    num_cols = 3
+    num_rows = (len(card_info) + num_cols - 1) // num_cols
+
+    with stylable_container(
+        key="container_with_border",
+        css_styles="""
+            {
+                display: flex;
+                align-items: center;
+                flex-wrap: wrap;
+            }
+            """,
+    ):
+        for row in range(num_rows):
+            cols = st.columns(num_cols)
+            for col in range(num_cols):
+                index = row * num_cols + col
+                if index < len(card_info):
+                    card = card_info[index]
+                    with cols[col]:
+                        with stylable_container(
+                            key="inside_container_with_border",
+                            css_styles="""
+                                {
+                                    height: 500px;
+                                    background-color: #f8f9fa;
+                                    border-radius: 10px;
+                                    box-shadow: 0 4px 8px 0 rgba(0, 0, 0, 0.1);
+                                    display: flex;
+                                    justify-content: center;
+                                    align-items: center;
+                                    flex-wrap: wrap;
+                                    padding:10px;
+                                """,
+                        ):
+                            st.markdown(
+                                f'''
+                                <div class="card">
+                                    <h2>{card["title"]}</h2>
+                                    <p>{card["description"]}</p>
+                                </div>
+                                ''', unsafe_allow_html=True)
+                            if st.button(f"Go to {card['title']}", key=card["key"]):
+                                st.session_state.page = card["key"]
+
+if __name__ == '__main__':
+    main()