https://www.prisma.io/ logo
Join Slack
Powered by
Hi, I am getting an error that I don’t know how to...
# orm-help
j
Hi, I am getting an error that I don’t know how to interpret. Checking the docker logs and see a lot of errors matching given request ID that looks like this: 
{"key":"error/unhandled","requestId":"local:ckfpi7y15corc0a36a22vlk6a","clientId":"default@default","payload":{"exception":"java.util.concurrent.RejectedExecutionException: Task slick.basic.BasicBackend$DatabaseDef$$anon$3@19ab3f35 rejected from slick.util.AsyncExecutor$$anon$1$$anon$2@195d2ec6[Running, pool size = 9, active threads = 9, queued tasks = 1000, completed tasks = 19478188]","query":"query ($where: RecruitmentWhereInput) {\n  recruitmentsConnection(where: $where) {\n    aggregate {\n      count\n    }\n  }\n}\n","variables":"{\"where\":{\"company\":{\"id\":\"ckfi0g67i7dyr0a36427kqxe5\"},\"state\":\"ACTIVE\"}}","code":"0","stack_trace":"java.util.concurrent.ThreadPoolExecutor$AbortPolicy.rejectedExecution(ThreadPoolExecutor.java:2063)\\n java.util.concurrent.ThreadPoolExecutor.reject(ThreadPoolExecutor.java:830)\\n java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:1379)\\n slick.util.AsyncExecutor$$anon$1$$anon$4.execute(AsyncExecutor.scala:161)\\n slick.basic.BasicBackend$DatabaseDef.runSynchronousDatabaseAction(BasicBackend.scala:265)\\n slick.basic.BasicBackend$DatabaseDef.runSynchronousDatabaseAction$(BasicBackend.scala:263)\\n slick.jdbc.JdbcBackend$DatabaseDef.runSynchronousDatabaseAction(JdbcBackend.scala:37)\\n slick.basic.BasicBackend$DatabaseDef.slick$basic$BasicBackend$DatabaseDef$$runInContextInline(BasicBackend.scala:242)\\n slick.basic.BasicBackend$DatabaseDef.runInContextSafe(BasicBackend.scala:148)\\n slick.basic.BasicBackend$DatabaseDef.runInContext(BasicBackend.scala:142)\\n slick.basic.BasicBackend$DatabaseDef.runInContext$(BasicBackend.scala:141)\\n slick.jdbc.JdbcBackend$DatabaseDef.runInContext(JdbcBackend.scala:37)\\n slick.basic.BasicBackend$DatabaseDef.runInternal(BasicBackend.scala:77)\\n slick.basic.BasicBackend$DatabaseDef.runInternal$(BasicBackend.scala:76)\\n slick.jdbc.JdbcBackend$DatabaseDef.runInternal(JdbcBackend.scala:37)\\n slick.basic.BasicBackend$DatabaseDef.run(BasicBackend.scala:74)\\n slick.basic.BasicBackend$DatabaseDef.run$(BasicBackend.scala:74)\\n slick.jdbc.JdbcBackend$DatabaseDef.run(JdbcBackend.scala:37)\\n com.prisma.api.connector.jdbc.impl.JdbcDataResolver.runAttached(JdbcDataResolver.scala:45)\\n com.prisma.api.connector.jdbc.impl.JdbcDataResolver.$anonfun$countByModel$1(JdbcDataResolver.scala:95)\\n com.prisma.metrics.micrometer.MicrometerTimerMetric.timeFuture(MicrometerMetrics.scala:64)\\n com.prisma.api.connector.jdbc.impl.JdbcDataResolver.performWithTiming(JdbcDataResolver.scala:98)\\n com.prisma.api.connector.jdbc.impl.JdbcDataResolver.countByModel(JdbcDataResolver.scala:95)\\n com.prisma.api.resolver.CountNodesDeferredResolver.resolve(CountNodesDeferredResolver.scala:10)\\n com.prisma.api.resolver.DeferredResolverImpl.$anonfun$resolve$5(DeferredResolverImpl.scala:93)\\n scala.collection.TraversableLike.$anonfun$map$1(TraversableLike.scala:233)\\n scala.collection.immutable.Map$Map1.foreach(Map.scala:125)\\n scala.collection.TraversableLike.map(TraversableLike.scala:233)\\n scala.collection.TraversableLike.map$(TraversableLike.scala:226)\\n scala.collection.AbstractTraversable.map(Traversable.scala:104)\\n com.prisma.api.resolver.DeferredResolverImpl.resolve(DeferredResolverImpl.scala:92)\\n sangria.execution.Resolver.sangria$execution$Resolver$$resolveDeferred(Resolver.scala:766)\\n sangria.execution.Resolver$ParentDeferredContext.$anonfun$init$4(Resolver.scala:1230)\\n sangria.execution.Resolver$ParentDeferredContext.$anonfun$init$4$adapted(Resolver.scala:1230)\\n scala.collection.Iterator.foreach(Iterator.scala:937)\\n scala.collection.Iterator.foreach$(Iterator.scala:937)\\n scala.collection.AbstractIterator.foreach(Iterator.scala:1425)\\n scala.collection.IterableLike.foreach(IterableLike.scala:70)\\n scala.collection.IterableLike.foreach$(IterableLike.scala:69)\\n scala.collection.AbstractIterable.foreach(Iterable.scala:54)\\n sangria.execution.Resolver$ParentDeferredContext.$anonfun$init$3(Resolver.scala:1230)\\n sangria.execution.Resolver$ParentDeferredContext.$anonfun$init$3$adapted(Resolver.scala:1229)\\n scala.util.Success.foreach(Try.scala:249)\\n scala.concurrent.Future.$anonfun$foreach$1$adapted(Future.scala:225)\\n scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60)\\n akka.dispatch.BatchingExecutor$AbstractBatch.processBatch(BatchingExecutor.scala:55)\\n akka.dispatch.BatchingExecutor$BlockableBatch.$anonfun$run$1(BatchingExecutor.scala:91)\\n scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:12)\\n scala.concurrent.BlockContext$.withBlockContext(BlockContext.scala:81)\\n akka.dispatch.BatchingExecutor$BlockableBatch.run(BatchingExecutor.scala:91)\\n akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:40)\\n akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(ForkJoinExecutorConfigurator.scala:44)\\n akka.dispatch.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)\\n akka.dispatch.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)\\n akka.dispatch.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)\\n akka.dispatch.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)","message":"Task slick.basic.BasicBackend$DatabaseDef$$anon$3@19ab3f35 rejected from slick.util.AsyncExecutor$$anon$1$$anon$2@195d2ec6[Running, pool size = 9, active threads = 9, queued tasks = 1000, completed tasks = 19478188]"}}
Can anyone please guide me in the right direction? Thanks 🙏🏼
r
Hey @Josef Henryson 👋 Your Prisma server is overloaded with requests, What version of Prisma are you on currently?
j
1.34
Thanks @Ryan! Any idea on how I can handle this? I know this requests makes a lot of aggregations etc.
r
One way would be to increase the server resources.
j
RAM or CPU? We just increased CPU on that machine
r
RAM also preferably as the JVM would use that.
🙏🏼 1
j
Thanks, we’’' try that. Otherwise, do you think there are better ways to design the queries/aggregation?
We currently have 4GB, any recommended size from Prisma?
r
4 would be quite less in production. I would suggest somewhere around 8-12.
j
Thank you, we’ll try that. 🙏🏼
Just to make sure I’m not doing anything stupid, can you have a quick glance at my code below to see if there is anything I can improve codewise for performance?
Copy code
const Company = prismaObjectType({
    name: 'Company',
    definition: t => {
        t.prismaFields(['*'])
        t.field('employeeCount', {
            type: 'Int',
            resolve: async (root, args, ctx) => {
                return await ctx.prisma.usersConnection({ where: { employer: { id: root.id } }}).aggregate().count()
            }
        })
        t.field('activeRecruitmentsCount', {
            type: 'Int',
            resolve: async (root, args, ctx) => {
                return await ctx.prisma.recruitmentsConnection({ where: { company: { id: root.id }, state: 'ACTIVE' }}).aggregate().count()
            }
        })
        t.field('closedRecruitmentsCount', {
            type: 'Int',
            resolve: async (root, args, ctx) => {
                return await ctx.prisma.recruitmentsConnection({ where: { company: { id: root.id }, state: 'CLOSED' }}).aggregate().count()
            }
        })
        t.field('messageLogCount', {
            type: 'Int',
            resolve: async (root, args, ctx) => {
                const logs = await ctx.prisma.company({ id: root.id }).messageLogs()
                return logs ? logs.length : 0
            }
        })
        t.field('hasApplications', {
            type: 'Boolean',
            resolve: async (root, args, ctx) => {
                return await ctx.prisma.recruitmentsConnection({ where: { company: { id: root.id }, applications_some: { id_not_in: [] } }}).aggregate().count() > 0
            }
        })
        t.field('hasAddons', {
            type: 'Boolean',
            resolve: async (root, args, ctx) => {
                return await ctx.prisma.recruitmentsConnection({ where: { company: { id: root.id }, recruitmentAddons_some: { id_not_in: [] } }}).aggregate().count() > 0
            }
        })
        t.field('hasChannels', {
            type: 'Boolean',
            resolve: async (root, args, ctx) => {
                return await ctx.prisma.recruitmentsConnection({ where: { company: { id: root.id }, publishChannels_some: { id_not_in: [] } }}).aggregate().count() > 0
            }
        })
    }
})
Thanks 🙏🏼
2 Views
Open in Slack
PreviousNext
Powered by