Where communities thrive


  • Join over 1.5M+ people
  • Join over 100K+ communities
  • Free without limits
  • Create your own community
People
Repo info
Activity
  • 02:08
    mribeirodantas synchronize #3568
  • 01:38
    saulpierotti-ebi opened #3581
  • Jan 27 23:09
    marcodelapierre synchronize #3580
  • Jan 27 17:47
    bentsherman labeled #2841
  • Jan 27 17:44
    bentsherman labeled #3110
  • Jan 27 16:46
    bentsherman ready_for_review #3579
  • Jan 27 16:33
    bentsherman synchronize #3579
  • Jan 27 16:33

    bentsherman on 3496-trace-metrics-cgroup

    Fix condition Signed-off-by: B… (compare)

  • Jan 27 14:45
    pditommaso commented #3555
  • Jan 27 14:37
    marcodelapierre synchronize #3580
  • Jan 27 14:26
    l-modolo commented #3477
  • Jan 27 14:15
    l-modolo synchronize #3477
  • Jan 27 13:58
    pditommaso commented #3580
  • Jan 27 13:50
    bentsherman commented #3579
  • Jan 27 13:27
    marcodelapierre commented #3580
  • Jan 27 13:25
    marcodelapierre synchronize #3580
  • Jan 27 13:18
    marcodelapierre synchronize #3580
  • Jan 27 13:06
    marcodelapierre synchronize #3580
  • Jan 27 12:27
    jfy133 synchronize #3571
  • Jan 27 10:27
    marcodelapierre commented #3580
Paolo Di Tommaso
@pditommaso
@evanbiederstedt what's it somatic-variant-comparison-roslin-v4 (1).html ?
@Shellfishgene use .println
evanbiederstedt
@evanbiederstedt
@pditommaso Apologies, please delete. I tried to put an html in the browser quickly, and I think Gitter was open
Sorry all
Paolo Di Tommaso
@pditommaso
I see, no pb
evanbiederstedt
@evanbiederstedt
:embarrassment emoji:
grazie
Stijn van Dongen
@micans
@Shellfishgene I've improved the solution a bit; I wasn't happy about sorting based on filename; the solution below actually uses the sample names and sorts the lists based on that.
R1 = Channel.create()
R2 = Channel.create()

Channel.from(['Sample_a', ['a.R1.fastq', 'a.R2.fastq']]
           , ['Sample_b', ['b.R1.fastq', 'b.R2.fastq']]
           , ['Sample_c', ['c.R1.fastq', 'c.R2.fastq']])

  .separate ( R1, R2 ) { it -> (id, reads) = it; [ [id, reads[0]], [id, reads[1]] ] }

def sortfqlist(thelist) {
   thelist
   .sort { a,b -> a[0] <=> b[0] }
   .collect { it[1] }
}

R1.toList()
  .subscribe onNext: { list = sortfqlist(it); println "list1: " + list }

R2.toList()
  .subscribe onNext: { list = sortfqlist(it); println "list2: " + list }
Paolo Di Tommaso
@pditommaso
well, it looks NF is powering cool stuff
Stijn van Dongen
@micans
well you know I love NF. it's a lot of fun programming in it!
Paolo Di Tommaso
@pditommaso
I was referring @evanbiederstedt link :)
Stijn van Dongen
@micans
hahaha
that's so funny :-)
It's mine, I'm claiming it
Paolo Di Tommaso
@pditommaso
your love is unquestioned, tho :)
Stijn van Dongen
@micans
it's powerful love
Paolo Di Tommaso
@pditommaso
the best one
Stijn van Dongen
@micans
I know, reminds me of that year there were three songs all called the 'the power of love'
Huwey Lewis and the News, Jennifer Rush, and Frankie goes to Hollywood IIRC
Paolo Di Tommaso
@pditommaso
lol
Seth
@sstadick
Hi! Is there any documentation surrounding the -params-file option? I see it referenced in old issues, and kicking around in the source code, but it doesn't look like it's used anymore?
Tobias "Tobi" Schraink
@tobsecret
@sstadick I typically write bash scripts that run nextflow with params specified
Paolo Di Tommaso
@pditommaso
Just specify a yaml or json file
Seth
@sstadick
:thumbsup: I didn't realize it was going to be that simple.
Paolo Di Tommaso
@pditommaso
:stuck_out_tongue_closed_eyes:
Shellfishgene
@Shellfishgene
@micans Thanks for the update!
Chadi Saad
@chadisaad
Good morning ! How can I get easly for a specific nextflow job, the list of all child process (executed via slurm) ?
Pierre Lindenbaum
@lindenb
following this conversation on twitter with @pditommaso ( https://twitter.com/yokofakun/status/1159072968158457856 ) I'm trying to implement some new operators. It's not the final design of the source, (I don't think using the notation 'splitter' is a good choice because we don't really read any line). However , it doesn't work.
I implemented a splitter: https://github.com/lindenb/nextflow/blob/pl_htsjdk_op/modules/nextflow/src/main/groovy/nextflow/extension/htsjdk/SamplesSplitter.groovy
I use this splitter in OperatorExt : https://github.com/lindenb/nextflow/blob/pl_htsjdk_op/modules/nextflow/src/main/groovy/nextflow/extension/OperatorEx.groovy#L1623
I compile './gradlew build -x test ` and when I want to run, I get the following error:
 cat test.nf 
Channel.fromPath("/home/lindenb/src/jvarkit-git/src/test/resources/toy.bam").
    splitSamples().
    dump()
$ ./nextflow run test.nf
N E X T F L O W  ~  version 19.08.0-SNAPSHOT
Launching `test.nf` [goofy_goldstine] - revision: f56eb762e4
Unknown method `splitSamples` on channel type
NF cannot find my operator. what am i missing in the code ?
Vũ Mạnh Tú
@glmanhtu

Hello guys. I'm trying to run nextflow with Kubernetes and have encountered some sort of problem with non-root user. Nextflow was trying to initialise a Pod but got an exception of "container init caused \"mkdir /mnt/tvu: permission denied". Below is the Kubernetes manifest generated by nextflow:

apiVersion: v1
kind: Pod
metadata:
  name: nf-68b883e7affa9dc5d6d5e721c75b21c4
  namespace: default
  labels: {app: nextflow, runName: sleepy-goodall, taskName: indexPeptides, processName: indexPeptides,
    sessionId: uuid-0e5b6c81-4527-4213-a9ba-16e40e424220}
spec:
  restartPolicy: Never
  containers:
  - name: nf-68b883e7affa9dc5d6d5e721c75b21c4
    image: omicsdi/crux:latest
    command: [/bin/bash, -ue, .command.run]
    workingDir: /mnt/tvu/work/68/b883e7affa9dc5d6d5e721c75b21c4
    volumeMounts:
    - {name: vol-1, mountPath: /mnt}
  securityContext: {runAsUser: 2801}
  volumes:
  - name: vol-1
    persistentVolumeClaim: {claimName: pride-pv-claim}

I have assigned rw permission to the persistent volume. When I removed the workingDir, the pod was started successfully and I was be able to cd into the /mnt/tvu/work/68/b883e7affa9dc5d6d5e721c75b21c4 folder. So, I suspect that the runAsUser and workingDir couldn't get along.
Is there anyone have experienced this issue?

Paolo Di Tommaso
@pditommaso
@lindenb try using ./launch.sh instead of nextflow script
then much simpler to test it using a test class
have a look at this example
and the invocation as operator
I would suggest also to open a draft pull request and keep a discuss thread there
Pierre Lindenbaum
@lindenb
@pditommaso :thumbsup:
Philip Jonsson
@kpjonsson
Question: In Nextflow version 19.07.0.5106, I get WARN: The channelcreatemethod is deprecated -- it will be removed in a future release when I use the Channel.create() method, but I find nowhere any mention of what's replacing it. Is the warning wrong or is there some undocumented feature I'm missing?
Ghost
@ghost~57581dbcc2f0db084a1ccd04
Don't worry, it won't happen overnight
AFAIK you can safely already remove the stuff like ch_input = Channel.create()
Philip Jonsson
@kpjonsson
@MaxUlysse Got it, thanks.
Ghost
@ghost~57581dbcc2f0db084a1ccd04

And I do believe that was the important part:

to me the only use for create that makes sense is when used with choice

Paolo Di Tommaso
@pditommaso
this is just great, isn't it ?
Hugues Fontenelle
@huguesfontenelle
hi!
How do I read the documentation for an older release? ie 19.04
well I guess I can simply read in github ..
Paolo Di Tommaso
@pditommaso
indeed
evanbiederstedt
@evanbiederstedt

@pditommaso
this is just great, isn't it ?
https://twitter.com/yokofakun/status/1159468857934929922

Confirmed, this is great