text: import { processSubscription } from '@apps/subscriptions/services/subscriptions'
  import Subscription from '@apps/subscriptions/models/subscription'
  import Queue from '@core/objects/queue'
  
  const processor = async (req, job) => {
  
    const subscription = await Subscription.query(qb => {
      qb.select('subscriptions_subscriptions.*','subscriptions_subscription_details.*')
      qb.innerJoin('subscriptions_subscription_details','subscriptions_subscription_details.subscription_id','subscriptions_subscriptions.id')
      qb.where('subscriptions_subscriptions.id', job.data.subscription_id)
    }).fetch({
      transacting: req.trx
    })
  
    await processSubscription(req, {
      subscription
    })
  
  }
  
  const ProcessSubscriptionQueue = new Queue({
    queue: 'maha:worker',
    name: 'process_subscription',
    processor
  })
  
  export default ProcessSubscriptionQueue
  