diff --git a/src/modules/content-writer/content.writer.processor.ts b/src/modules/content-writer/content.writer.processor.ts
index 2543597..a004625 100644
--- a/src/modules/content-writer/content.writer.processor.ts
+++ b/src/modules/content-writer/content.writer.processor.ts
@@ -205,7 +205,7 @@ export class ContentWriterProcessor extends WorkerHost {
         }
         return {
             id: post.id,
-            // content: postContent,
+            content: pgPostCreateDto.content,
             //image: imageSuggestion,
             status: 'ready_to_post',
             telegramChatId,
diff --git a/src/modules/scheduler/scheduler.service.ts b/src/modules/scheduler/scheduler.service.ts
index dc3378d..d013c1f 100644
--- a/src/modules/scheduler/scheduler.service.ts
+++ b/src/modules/scheduler/scheduler.service.ts
@@ -1,6 +1,7 @@
 import { Injectable, Logger } from '@nestjs/common';
 import { Cron, CronExpression } from '@nestjs/schedule';
 import { TrendsService } from '../trends/trends.service';
+import {_toNum} from "../../shared/helper";
 
 @Injectable()
 export class SchedulerService {
@@ -14,6 +15,10 @@ export class SchedulerService {
      */
     @Cron('0 */2 * * *')
     async scheduledCollection() {
+        if(_toNum(process.env.X_NEWS_ALLOW_COLLECT_TREND) != 1) {
+            this.logger.error('Not allow collecting collect ..');
+            return;
+        }
         //clear before
         this.logger.log('🧹 Running daily cleanup...');
         const deleted = await this.trendsService.cleanupOldTrends(2);
@@ -44,6 +49,10 @@ export class SchedulerService {
      */
     @Cron('0 3 * * *')
     async scheduledCleanup() {
+        if(_toNum(process.env.X_NEWS_ALLOW_COLLECT_TREND) != 1) {
+            this.logger.error('Not allow clear ..');
+            return;
+        }
         this.logger.log('🧹 Running daily cleanup...');
         const deleted = await this.trendsService.cleanupOldTrends(3);
         this.logger.log(`🧹 Cleanup done: removed ${deleted} old trends`);
diff --git a/src/shared/pg.post.service.ts b/src/shared/pg.post.service.ts
index 3737f4f..9299d7d 100644
--- a/src/shared/pg.post.service.ts
+++ b/src/shared/pg.post.service.ts
@@ -1,6 +1,7 @@
 import {Injectable} from "@nestjs/common";
 import {PrismaService} from "../../prisma/prisma.service";
 import {Post, Prisma} from "../generated/prisma/client";
+import {_toNum} from "./helper";
 
 @Injectable()
 export class PgPostService {
@@ -18,6 +19,13 @@ export class PgPostService {
     }
 
     async createPost(data: Prisma.PostCreateInput): Promise<Post> {
+        if(_toNum(process.env.X_NEWS_ALLOW_SAVE_POST_CONTENT) != 1) {
+            console.error('Not allow save ..');
+            // @ts-ignore
+            return {
+                id: 0
+            };
+        }
         return this.prisma.post.create({
             data,
         });