Merge branch 'cognify_adjusment_crewai_demo' of https://github.com/topoteretes/cognee into cognify_adjusment_crewai_demo

This commit is contained in:
hajdul88 2025-06-04 13:16:21 +02:00
commit 68284a7ade
4 changed files with 17 additions and 12 deletions

View file

@ -39,14 +39,16 @@ export default function ActivityLog({ ref }: ActivityLogProps) {
})); }));
return ( return (
<div className="flex flex-col gap-2 overflow-y-auto max-h-96" id="activityLogContainer"> <div className="overflow-y-auto max-h-96" id="activityLogContainer">
{activityLog.map((activity) => ( <div className="flex flex-col-reverse gap-2">
<div key={activity.id} className="flex gap-2 items-top"> {activityLog.map((activity) => (
<span className="flex-1/3 text-xs text-gray-300 whitespace-nowrap mt-1.5">{formatter.format(activity.timestamp)}: </span> <div key={activity.id} className="flex gap-2 items-top">
<span className="flex-2/3 text-white whitespace-normal">{activity.activity}</span> <span className="flex-1/3 text-xs text-gray-300 whitespace-nowrap mt-1.5">{formatter.format(activity.timestamp)}: </span>
</div> <span className="flex-2/3 text-white whitespace-normal">{activity.activity}</span>
))} </div>
{!activityLog.length && <span className="text-white">No activity logged.</span>} ))}
{!activityLog.length && <span className="text-white">No activity logged.</span>}
</div>
</div> </div>
); );
} }

View file

@ -5,8 +5,8 @@ const NODE_COLORS = {
Document: formatHex(colors.blue[500]), Document: formatHex(colors.blue[500]),
Chunk: formatHex(colors.green[500]), Chunk: formatHex(colors.green[500]),
Entity: formatHex(colors.yellow[500]), Entity: formatHex(colors.yellow[500]),
EntityType: formatHex(colors.purple[500]), EntityType: formatHex(colors.purple[800]),
NodeSet: formatHex(colors.indigo[800]), NodeSet: formatHex(colors.indigo[300]),
GitHubUser: formatHex(colors.gray[300]), GitHubUser: formatHex(colors.gray[300]),
Comment: formatHex(colors.amber[500]), Comment: formatHex(colors.amber[500]),
Issue: formatHex(colors.red[500]), Issue: formatHex(colors.red[500]),

View file

@ -4,7 +4,7 @@ from cognee.modules.pipelines.utils import generate_pipeline_id, generate_pipeli
def get_crewai_pipeline_run_id(user_id: UUID): def get_crewai_pipeline_run_id(user_id: UUID):
dataset_id = uuid5(NAMESPACE_OID, "GitHub") dataset_id = uuid5(NAMESPACE_OID, "Github")
pipeline_id = generate_pipeline_id(user_id, "github_pipeline") pipeline_id = generate_pipeline_id(user_id, "github_pipeline")
pipeline_run_id = generate_pipeline_run_id(pipeline_id, dataset_id) pipeline_run_id = generate_pipeline_run_id(pipeline_id, dataset_id)

View file

@ -128,11 +128,14 @@ async def ingest_data(
existing_datasets = await get_authorized_existing_datasets( existing_datasets = await get_authorized_existing_datasets(
user=user, permission_type="write", datasets=[dataset_name] user=user, permission_type="write", datasets=[dataset_name]
) )
dataset = await load_or_create_datasets( datasets = await load_or_create_datasets(
dataset_names=[dataset_name], dataset_names=[dataset_name],
existing_datasets=existing_datasets, existing_datasets=existing_datasets,
user=user, user=user,
) )
dataset = next(
(dataset for dataset in datasets if dataset.name == "Github")
)
# Check to see if data should be updated # Check to see if data should be updated
data_point = ( data_point = (