Can't able to persist data into db when watcher is running.

[tirthrajsinh-fens]

Hello Everyone I am Watching Kubernates Jobs through kubernates client api . and also I want to add jobs schema into postgres sql when Job's Action is ADDED, I mentioned my snippet below here.

final CountDownLatch watchLatch = new CountDownLatch(1);
try (Watch watch = kubernetesClient.batch().v1().jobs().watch(new Watcher<Job>() {

@Override
public void eventReceived(Action action, Job job) {

    String jobUUID = job.getMetadata().getUid();
    String cronJobUUID = "c46c6097-705e-41da-b1e5-1a7e0750a682";
    String jobName = job.getMetadata().getName();
    LocalDateTime startTime = LocalDateTime.now();
    LocalDateTime endTime = LocalDateTime.now();


    if (action.name() == "ADDED") {
    jobsHistory.setName(jobName);  ;
    jobsHistory.setCron_job_id(cronJobUUID);
    jobsHistory.setId(jobUUID);
    jobsHistory.setJobStatus(JobsHistory.WatchJobStatus.SCHEDULE);
    jobsHistory.setStart_time(startTime);
    jobsHistory.setEnd_time(endTime);
    System.out.println("Inside Added");
    jobsHistory.persist();
    }

    @Override
    public void onClose(WatcherException e) {
    }
    })) {
    watchLatch.await(2, TimeUnit.MINUTES);
    } catch (InterruptedException e) {
    
    System.out.println("interrupted sorry");
    } catch (Exception e) {
    System.out.println(e);
    }

After Executing Above Code Getting Below Error , Can anyone Help How Can I Resolve ?

Unhandled exception encountered in watcher event handler: javax.enterprise.context.ContextNotActiveException at io.quarkus.arc.impl.ClientProxies.getDelegate(ClientProxies.java:46) at io.quarkus.hibernate.orm.runtime.RequestScopedSessionHolder_ClientProxy.arc$delegate(Unknown Source) at io.quarkus.hibernate.orm.runtime.RequestScopedSessionHolder_ClientProxy.getOrCreateSession(Unknown Source) at io.quarkus.hibernate.orm.runtime.session.TransactionScopedSession.acquireSession(TransactionScopedSession.java:104) at io.quarkus.hibernate.orm.runtime.session.TransactionScopedSession.contains(TransactionScopedSession.java:313) at io.quarkus.hibernate.orm.runtime.session.ForwardingSession.contains(ForwardingSession.java:148) at org.hibernate.Session_5b93bee577ae2f8d76647de04cfab36afbf52958_Synthetic_ClientProxy.contains(Unknown Source) at io.quarkus.hibernate.orm.panache.common.runtime.AbstractJpaOperations.isPersistent(AbstractJpaOperations.java:126) at io.quarkus.hibernate.orm.panache.PanacheEntityBase.isPersistent(PanacheEntityBase.java:94) at org.acme.Resource.WatchJobs$2.eventReceived(WatchJobs.java:176) at org.acme.Resource.WatchJobs$2.eventReceived(WatchJobs.java:140) at io.fabric8.kubernetes.client.utils.WatcherToggle.eventReceived(WatcherToggle.java:49) at io.fabric8.kubernetes.client.dsl.internal.AbstractWatchManager.eventReceived(AbstractWatchManager.java:203) at io.fabric8.kubernetes.client.dsl.internal.AbstractWatchManager.onMessage(AbstractWatchManager.java:306) at io.fabric8.kubernetes.client.dsl.internal.WatcherWebSocketListener.onMessage(WatcherWebSocketListener.java:68) at io.fabric8.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl$1.onMessage(OkHttpWebSocketImpl.java:97) at okhttp3.internal.ws.RealWebSocket.onReadMessage(RealWebSocket.java:322) at okhttp3.internal.ws.WebSocketReader.readMessageFrame(WebSocketReader.java:219) at okhttp3.internal.ws.WebSocketReader.processNextFrame(WebSocketReader.java:105) at okhttp3.internal.ws.RealWebSocket.loopReader(RealWebSocket.java:273) at okhttp3.internal.ws.RealWebSocket$1.onResponse(RealWebSocket.java:209) at okhttp3.RealCall$AsyncCall.execute(RealCall.java:174) at okhttp3.internal.NamedRunnable.run(NamedRunnable.java:32) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) at java.base/java.lang.Thread.run(Thread.java:833)

[manusa]

Not sure if this is exactly what you asking.

The following JBang script (among other things) deploys and populates a PostgreSQL database once the process is up and running.

https://github.com/redhat-developer-demos/northwind-traders/blob/a7de0dfba95daa403ed7a7b8dbca538bf1ecfb0c/prod/PrepareEnvironment.java