"""Produces IPHAS Data Release 2 using an MPI computing cluster."""
from IPython import parallel
from astropy import log

__author__ = 'Geert Barentsen'

# Create the cluster view
client = parallel.Client('/home/gb/.config/ipython/profile_mpi/security/ipcontroller-seaming-client.json')
cluster = client[:]
log.info('Using {0} cores'.format(len(cluster)))

# Sync imports across all nodes
with client[:].sync_imports():
    # Make sure the IPHAS DR2 module is in the path
    import os
    import sys
    sys.path.append('/home/gb/dev/iphas-dr2')
    client[:].execute("sys.path.append('/home/gb/dev/iphas-dr2')", block=True)
    # Import DR2 generation modules
    from dr2 import constants
    from dr2 import seaming
    from dr2 import concatenating

client[:].execute('reload(constants)', block=True)
client[:].execute('reload(seaming)', block=True)
client[:].execute('reload(concatenating)', block=True)

seaming.seam(cluster)
#concatenating.concatenate(cluster)

"""Produces IPHAS Data Release 2 using an MPI computing cluster."""
from IPython import parallel
from astropy import log

__author__ = 'Geert Barentsen'

# Create the cluster view
client = parallel.Client('/home/gb/.config/ipython/profile_mpi/security/ipcontroller-seaming-client.json')
cluster = client[:]
log.info('Using {0} cores'.format(len(cluster)))

# Sync imports across all nodes
with client[:].sync_imports():
    # Make sure the IPHAS DR2 module is in the path
    import os
    import sys
    sys.path.append('/home/gb/dev/iphas-dr2')
    client[:].execute("sys.path.append('/home/gb/dev/iphas-dr2')", block=True)
    # Import DR2 generation modules
    from dr2 import constants
    from dr2 import seaming
    from dr2 import concatenating

client[:].execute('reload(constants)', block=True)
client[:].execute('reload(seaming)', block=True)
client[:].execute('reload(concatenating)', block=True)

#seaming.seam(cluster)
concatenating.concatenate(client[0,4,8,12])

Allow Glazebrook to be executed in a multi-pass fashion + parallelise
Allow Glazebrook to be executed in a multi-pass fashion + parallelise

  """Produces IPHAS Data Release 2 using an MPI computing cluster."""
  from IPython import parallel
  from astropy import log
  
  __author__ = 'Geert Barentsen'
  
  # Create the cluster view
  client = parallel.Client('/home/gb/.config/ipython/profile_mpi/security/ipcontroller-seaming-client.json')
  cluster = client[:]
  log.info('Using {0} cores'.format(len(cluster)))
  
  # Sync imports across all nodes
  with client[:].sync_imports():
      # Make sure the IPHAS DR2 module is in the path
      import os
      import sys
      sys.path.append('/home/gb/dev/iphas-dr2')
      client[:].execute("sys.path.append('/home/gb/dev/iphas-dr2')", block=True)
      # Import DR2 generation modules
      from dr2 import constants
      from dr2 import seaming
      from dr2 import concatenating
  
  client[:].execute('reload(constants)', block=True)
  client[:].execute('reload(seaming)', block=True)
  client[:].execute('reload(concatenating)', block=True)
  
- seaming.seam(cluster)
+ #seaming.seam(cluster)
- #concatenating.concatenate(cluster)
+ concatenating.concatenate(client[0,4,8,12])
  
Allow Glazebrook to be executed in a multi-pass fashion + parallelise
## Code Before:
"""Produces IPHAS Data Release 2 using an MPI computing cluster."""
from IPython import parallel
from astropy import log

__author__ = 'Geert Barentsen'

# Create the cluster view
client = parallel.Client('/home/gb/.config/ipython/profile_mpi/security/ipcontroller-seaming-client.json')
cluster = client[:]
log.info('Using {0} cores'.format(len(cluster)))

# Sync imports across all nodes
with client[:].sync_imports():
    # Make sure the IPHAS DR2 module is in the path
    import os
    import sys
    sys.path.append('/home/gb/dev/iphas-dr2')
    client[:].execute("sys.path.append('/home/gb/dev/iphas-dr2')", block=True)
    # Import DR2 generation modules
    from dr2 import constants
    from dr2 import seaming
    from dr2 import concatenating

client[:].execute('reload(constants)', block=True)
client[:].execute('reload(seaming)', block=True)
client[:].execute('reload(concatenating)', block=True)

seaming.seam(cluster)
#concatenating.concatenate(cluster)

## Instruction:
Allow Glazebrook to be executed in a multi-pass fashion + parallelise
## Code After:
"""Produces IPHAS Data Release 2 using an MPI computing cluster."""
from IPython import parallel
from astropy import log

__author__ = 'Geert Barentsen'

# Create the cluster view
client = parallel.Client('/home/gb/.config/ipython/profile_mpi/security/ipcontroller-seaming-client.json')
cluster = client[:]
log.info('Using {0} cores'.format(len(cluster)))

# Sync imports across all nodes
with client[:].sync_imports():
    # Make sure the IPHAS DR2 module is in the path
    import os
    import sys
    sys.path.append('/home/gb/dev/iphas-dr2')
    client[:].execute("sys.path.append('/home/gb/dev/iphas-dr2')", block=True)
    # Import DR2 generation modules
    from dr2 import constants
    from dr2 import seaming
    from dr2 import concatenating

client[:].execute('reload(constants)', block=True)
client[:].execute('reload(seaming)', block=True)
client[:].execute('reload(concatenating)', block=True)

#seaming.seam(cluster)
concatenating.concatenate(client[0,4,8,12])
