@@ -70,7 +70,7 @@ def test_can_create_pipeline(providers, params):
70
70
71
71
def test_pipeline_can_compute_dspacing_result (providers , params ):
72
72
pipeline = sciline .Pipeline (providers , params = params )
73
- pipeline = powder .set_pixel_mask_filenames (pipeline , [])
73
+ pipeline = powder .with_pixel_mask_filenames (pipeline , [])
74
74
result = pipeline .compute (IofDspacing )
75
75
assert result .sizes == {
76
76
'dspacing' : len (params [DspacingBins ]) - 1 ,
@@ -80,7 +80,7 @@ def test_pipeline_can_compute_dspacing_result(providers, params):
80
80
81
81
def test_workflow_is_deterministic (providers , params ):
82
82
pipeline = sciline .Pipeline (providers , params = params )
83
- pipeline = powder .set_pixel_mask_filenames (pipeline , [])
83
+ pipeline = powder .with_pixel_mask_filenames (pipeline , [])
84
84
# This is Sciline's default scheduler, but we want to be explicit here
85
85
scheduler = sciline .scheduler .DaskScheduler ()
86
86
graph = pipeline .get (IofDspacing , scheduler = scheduler )
@@ -91,7 +91,7 @@ def test_workflow_is_deterministic(providers, params):
91
91
92
92
def test_pipeline_can_compute_intermediate_results (providers , params ):
93
93
pipeline = sciline .Pipeline (providers , params = params )
94
- pipeline = powder .set_pixel_mask_filenames (pipeline , [])
94
+ pipeline = powder .with_pixel_mask_filenames (pipeline , [])
95
95
result = pipeline .compute (NormalizedByProtonCharge [SampleRun ])
96
96
assert set (result .dims ) == {'segment' , 'wire' , 'counter' , 'strip' , 'module' }
97
97
@@ -101,7 +101,7 @@ def test_pipeline_group_by_two_theta(providers, params):
101
101
dim = 'two_theta' , unit = 'rad' , start = 0.8 , stop = 2.4 , num = 17
102
102
)
103
103
pipeline = sciline .Pipeline (providers , params = params )
104
- pipeline = powder .set_pixel_mask_filenames (pipeline , [])
104
+ pipeline = powder .with_pixel_mask_filenames (pipeline , [])
105
105
result = pipeline .compute (IofDspacingTwoTheta )
106
106
assert result .sizes == {
107
107
'two_theta' : 16 ,
@@ -116,7 +116,7 @@ def test_pipeline_wavelength_masking(providers, params):
116
116
wmax = sc .scalar (0.21 , unit = "angstrom" )
117
117
params [WavelengthMask ] = lambda x : (x > wmin ) & (x < wmax )
118
118
pipeline = sciline .Pipeline (providers , params = params )
119
- pipeline = powder .set_pixel_mask_filenames (pipeline , [])
119
+ pipeline = powder .with_pixel_mask_filenames (pipeline , [])
120
120
masked_sample = pipeline .compute (MaskedData [SampleRun ])
121
121
assert 'wavelength' in masked_sample .bins .masks
122
122
sum_in_masked_region = (
@@ -135,7 +135,7 @@ def test_pipeline_two_theta_masking(providers, params):
135
135
tmax = sc .scalar (1.2 , unit = "rad" )
136
136
params [TwoThetaMask ] = lambda x : (x > tmin ) & (x < tmax )
137
137
pipeline = sciline .Pipeline (providers , params = params )
138
- pipeline = powder .set_pixel_mask_filenames (pipeline , [])
138
+ pipeline = powder .with_pixel_mask_filenames (pipeline , [])
139
139
masked_sample = pipeline .compute (MaskedData [SampleRun ])
140
140
assert 'two_theta' in masked_sample .bins .masks
141
141
sum_in_masked_region = (
0 commit comments