Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
12 changes: 0 additions & 12 deletions src/main/groovy/seqeralabs/plugin/NfNIMExtension.groovy
Original file line number Diff line number Diff line change
Expand Up @@ -18,9 +18,7 @@ package seqeralabs.plugin

import groovy.transform.CompileStatic
import nextflow.Session
import nextflow.plugin.extension.Function
import nextflow.plugin.extension.PluginExtensionPoint

/**
* Implements a custom function which can be imported by
* Nextflow scripts.
Expand All @@ -32,14 +30,4 @@ class NfNIMExtension extends PluginExtensionPoint {
protected void init(Session session) {
}

/**
* Say hello to the given target.
*
* @param target
*/
@Function
void sayHello(String target) {
println "Hello, ${target}!"
}

}
11 changes: 5 additions & 6 deletions src/main/groovy/seqeralabs/plugin/NfNIMFactory.groovy
Original file line number Diff line number Diff line change
Expand Up @@ -18,19 +18,18 @@ package seqeralabs.plugin

import groovy.transform.CompileStatic
import nextflow.Session
import nextflow.trace.TraceObserver
import nextflow.trace.TraceObserverFactory

import nextflow.trace.TraceObserverFactoryV2
import nextflow.trace.TraceObserverV2
/**
* Implements a factory object required to create
* the {@link NfNIMObserver} instance.
*/
@CompileStatic
class NfNIMFactory implements TraceObserverFactory {
class NfNIMFactory implements TraceObserverFactoryV2 {

@Override
Collection<TraceObserver> create(Session session) {
return List.<TraceObserver>of(new NfNIMObserver())
Collection<TraceObserverV2> create(Session session) {
return List.<TraceObserverV2>of(new NfNIMObserver())
}

}
15 changes: 2 additions & 13 deletions src/main/groovy/seqeralabs/plugin/NfNIMObserver.groovy
Original file line number Diff line number Diff line change
Expand Up @@ -18,24 +18,13 @@ package seqeralabs.plugin

import groovy.transform.CompileStatic
import groovy.util.logging.Slf4j
import nextflow.Session
import nextflow.trace.TraceObserver

import nextflow.trace.TraceObserverV2
/**
* Implements an observer that allows implementing custom
* logic on nextflow execution events.
*/
@Slf4j
@CompileStatic
class NfNIMObserver implements TraceObserver {

@Override
void onFlowCreate(Session session) {
println "Pipeline is starting! 🚀"
}
class NfNIMObserver implements TraceObserverV2 {

@Override
void onFlowComplete() {
// Pipeline completion - no message needed
}
}