yharaskrik

import { TensorFlowEmbeddings } from '@langchain/community/embeddings/tensorflow';
import {
    ChatPromptTemplate,
    HumanMessagePromptTemplate,
    SystemMessagePromptTemplate,
} from '@langchain/core/prompts';
import { ChatOpenAI } from '@langchain/openai';
import '@tensorflow/tfjs-node';
import { config } from 'dotenv';
import { MemoryVectorStore } from 'langchain/vectorstores/memory';

yharaskrik

import { BullModule } from '@nestjs/bull';
import { Module } from '@nestjs/common';
import { QueueGracefulShutdown } from './queue-graceful-shutdown';

const QUEUE_NAME = 'my-queue';

@Module({
    imports: [
        BullModule.registerQueue({
            name: QUEUE_NAME,

yharaskrik

interface SomeType {
  name: string;
  prop: string;
}

export abstract class MyStore<
  QueryVariables extends SomeType
> extends ComponentStore<any> {
  protected abstract readonly query$: Observable<Omit<QueryVariables, 'name'>>;